overwatch

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

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
)

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