overwatch

package

v0.0.0-...-7cb0e1f Latest Latest Go to latest Published: Jul 11, 2017 License: MIT Imports: 8 Imported by: 0

Details

Valid go.mod file

The Go module system was introduced in Go 1.11 and is the official dependency management solution for Go.
Redistributable license

Redistributable licenses place minimal restrictions on how software can be used, modified, and redistributed.
Tagged version

Modules with tagged versions give importers more predictable builds.
Stable version

When a project reaches major version v1 it is considered stable.
Learn more about best practices

Repository

github.com/9corp/9volt

Documentation ¶

Overview ¶

Overwatch package is responsible for:

listening for bad events from components
gracefully stopping all affected components
watching and waiting for the dependency to recover
starting all components back up

Index ¶

Constants
type Message
type Overwatch
- func New(cfg *config.Config, watchChannel <-chan *Message, components []base.IComponent) *Overwatch
- func (o *Overwatch) Start() error
- func (o *Overwatch) Stop() error

Constants ¶

View Source

const (
	WATCH_RETRY_INTERVAL  = time.Duration(5) * time.Second
	HEALTH_WATCH_DURATION = time.Duration(10) * time.Second

	ETCD_WATCHER_ERROR int = iota
	ETCD_GENERIC_ERROR
)

Variables ¶

This section is empty.

Functions ¶

This section is empty.

Types ¶

type Message ¶

type Message struct {
	Source    string
	Error     error
	ErrorType int
}

type Overwatch ¶

type Overwatch struct {
	Config       *config.Config
	WatchChannel <-chan *Message
	Looper       director.Looper
	WatchLooper  director.Looper
	Components   []base.IComponent

	Log log.FieldLogger

	base.Component
	// contains filtered or unexported fields
}

func New ¶

func New(cfg *config.Config, watchChannel <-chan *Message, components []base.IComponent) *Overwatch

func (*Overwatch) Start ¶

func (o *Overwatch) Start() error

func (*Overwatch) Stop ¶

func (o *Overwatch) Stop() error

TODO

Source Files ¶

View all Source files

overwatch.go

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL