monitor

type Context ¶

type Context interface {
	ZkZone() *zk.ZkZone
	StopChan() <-chan struct{}
	Inflight() *sync.WaitGroup
	InfluxAddr() string
	InfluxDB() string
	ExternalDir() string
}

Context is the context container that will be passed to plugin watchers.

type Monitor ¶

type Monitor struct {
	// contains filtered or unexported fields
}

Monitor is the engine that will start/stop plugin watchers. It itself is an implementation of Context.

func (this *Monitor) ExternalDir() string

func (this *Monitor) Inflight() *sync.WaitGroup

func (this *Monitor) InfluxAddr() string

func (this *Monitor) InfluxDB() string

func (this *Monitor) Init()

func (this *Monitor) ServeForever()

func (this *Monitor) Start()

func (this *Monitor) Stop()

func (this *Monitor) StopChan() <-chan struct{}

func (this *Monitor) ZkZone() *zk.ZkZone

type Setter ¶

type Setter interface {
	Set(key string)
}

type Watcher ¶

type Watcher interface {
	Init(Context)
	Run()
}

A Watcher is a plugin of monitor.