Documentation
¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type WatchBrokers ¶
type WatchBrokers struct {
Zkzone *zk.ZkZone
Stop <-chan struct{}
Tick time.Duration
Wg *sync.WaitGroup
}
WatchBrokers monitors aliveness of kafka brokers.
func (*WatchBrokers) Init ¶
func (this *WatchBrokers) Init(ctx monitor.Context)
func (*WatchBrokers) Run ¶
func (this *WatchBrokers) Run()
type WatchClusters ¶
type WatchClusters struct {
Zkzone *zk.ZkZone
Stop <-chan struct{}
Tick time.Duration
Wg *sync.WaitGroup
}
WatchClusters montor num of kafka clusters over the time.
func (*WatchClusters) Init ¶
func (this *WatchClusters) Init(ctx monitor.Context)
func (*WatchClusters) Run ¶
func (this *WatchClusters) Run()
type WatchConsumers ¶
type WatchConsumers struct {
Zkzone *zk.ZkZone
Stop <-chan struct{}
Tick time.Duration
Wg *sync.WaitGroup
// contains filtered or unexported fields
}
WatchConsumers monitors num of kafka online consumer groups over the time.
func (*WatchConsumers) Init ¶
func (this *WatchConsumers) Init(ctx monitor.Context)
func (*WatchConsumers) Run ¶
func (this *WatchConsumers) Run()
func (*WatchConsumers) Set ¶
func (this *WatchConsumers) Set(key string)
type WatchControllers ¶
type WatchControllers struct {
Zkzone *zk.ZkZone
Stop <-chan struct{}
Tick time.Duration
Wg *sync.WaitGroup
// contains filtered or unexported fields
}
func (*WatchControllers) Init ¶
func (this *WatchControllers) Init(ctx monitor.Context)
func (*WatchControllers) Run ¶
func (this *WatchControllers) Run()
type WatchReplicas ¶
type WatchReplicas struct {
Zkzone *zk.ZkZone
Stop <-chan struct{}
Tick time.Duration
Wg *sync.WaitGroup
}
WatchReplicas reports kafka out of sync partitions num over time.
func (*WatchReplicas) Init ¶
func (this *WatchReplicas) Init(ctx monitor.Context)
func (*WatchReplicas) Run ¶
func (this *WatchReplicas) Run()
type WatchTopics ¶
type WatchTopics struct {
Zkzone *zk.ZkZone
Stop <-chan struct{}
Tick time.Duration
Wg *sync.WaitGroup
// contains filtered or unexported fields
}
WatchTopics montor kafka total msg count over time.
func (*WatchTopics) Init ¶
func (this *WatchTopics) Init(ctx monitor.Context)
func (*WatchTopics) Run ¶
func (this *WatchTopics) Run()
type WatchZombieConsumerGroups ¶
type WatchZombieConsumerGroups struct {
Zkzone *zk.ZkZone
Stop <-chan struct{}
Tick time.Duration
Wg *sync.WaitGroup
}
func (*WatchZombieConsumerGroups) Init ¶
func (this *WatchZombieConsumerGroups) Init(ctx monitor.Context)
func (*WatchZombieConsumerGroups) Run ¶
func (this *WatchZombieConsumerGroups) Run()
Source Files
Click to show internal directories.
Click to hide internal directories.