monitor

Documentation

Index

• func RegisterWatcher(name string, factory func() Watcher)
• type Context
• type Monitor
  • 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 Watcher

Functions

func RegisterWatcher

func RegisterWatcher(name string, factory func() Watcher)

Types

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 (*Monitor) ExternalDir

func (this *Monitor) ExternalDir() string

func (*Monitor) Inflight

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

func (*Monitor) InfluxAddr

func (this *Monitor) InfluxAddr() string

func (*Monitor) InfluxDB

func (this *Monitor) InfluxDB() string

func (*Monitor) Init

func (this *Monitor) Init()

func (*Monitor) ServeForever

func (this *Monitor) ServeForever()

func (*Monitor) Start

func (this *Monitor) Start()

func (*Monitor) Stop

func (this *Monitor) Stop()

func (*Monitor) StopChan

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

func (*Monitor) ZkZone

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.