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()
Source Files
Click to show internal directories.
Click to hide internal directories.