Documentation
¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func NewSyncer ¶
func NewSyncer( reg prometheus.Registerer, logger log.Logger, cfg scrapeconfig.Config, pushClient api.EntryHandler, ) (*kafka.TargetSyncer, error)
Types ¶
type TargetManager ¶
type TargetManager struct {
// contains filtered or unexported fields
}
TargetManager manages a series of kafka targets.
func NewTargetManager ¶
func NewTargetManager( reg prometheus.Registerer, logger log.Logger, pushClient api.EntryHandler, scrapeConfigs []scrapeconfig.Config, ) (*TargetManager, error)
NewTargetManager creates a new Kafka managers.
func (*TargetManager) ActiveTargets ¶
func (tm *TargetManager) ActiveTargets() map[string][]target.Target
func (*TargetManager) AllTargets ¶
func (tm *TargetManager) AllTargets() map[string][]target.Target
func (*TargetManager) Ready ¶
func (tm *TargetManager) Ready() bool
Ready returns true if at least one Kafka target is active.
func (*TargetManager) Stop ¶
func (tm *TargetManager) Stop()
Source Files
Click to show internal directories.
Click to hide internal directories.