azureeventhubs

Documentation

Index

• func NewSyncer(reg prometheus.Registerer, logger log.Logger, cfg scrapeconfig.Config, ...) (*kafka.TargetSyncer, error)
• type TargetManager
  • func NewTargetManager(reg prometheus.Registerer, logger log.Logger, pushClient api.EntryHandler, ...) (*TargetManager, error)
  • func (tm *TargetManager) ActiveTargets() map[string][]target.Target
  • func (tm *TargetManager) AllTargets() map[string][]target.Target
  • func (tm *TargetManager) Ready() bool
  • func (tm *TargetManager) Stop()

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()