Documentation ¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
View Source
var (
ErrLogEntrySkipped = fmt.Errorf("skipped")
)
Functions ¶
This section is empty.
Types ¶
type WatchInfluxServer ¶
type WatchInfluxServer struct { Zkzone *zk.ZkZone Stop <-chan struct{} Tick time.Duration Wg *sync.WaitGroup // contains filtered or unexported fields }
func (*WatchInfluxServer) Init ¶
func (this *WatchInfluxServer) Init(ctx monitor.Context)
func (*WatchInfluxServer) Run ¶
func (this *WatchInfluxServer) Run()
type WatchInfluxdbInstances ¶
type WatchInfluxdbInstances struct { Zkzone *zk.ZkZone Stop <-chan struct{} Tick time.Duration Wg *sync.WaitGroup // contains filtered or unexported fields }
WatchInfluxdbInstances continuously pings influxdb servers.
func (*WatchInfluxdbInstances) Init ¶
func (this *WatchInfluxdbInstances) Init(ctx monitor.Context)
func (*WatchInfluxdbInstances) Run ¶
func (this *WatchInfluxdbInstances) Run()
Click to show internal directories.
Click to hide internal directories.