Versions in this module Expand all Collapse all v2 v2.5.2 Apr 27, 2022 Changes in this version + var SHA256 scram.HashGeneratorFcn = sha256.New + var SHA512 scram.HashGeneratorFcn = sha512.New + var TopicPollInterval = 30 * time.Second + type ConsumerDetails struct + GenerationID int32 + InitialOffset int64 + MemberID string + Partition int32 + Topic string + func (c ConsumerDetails) String() string + type RunnableTarget interface + type Target struct + func NewTarget(session sarama.ConsumerGroupSession, claim sarama.ConsumerGroupClaim, ...) *Target + func (t *Target) Details() interface{} + func (t *Target) DiscoveredLabels() model.LabelSet + func (t *Target) Labels() model.LabelSet + func (t *Target) Ready() bool + func (t *Target) Type() target.TargetType + type TargetDiscoverer interface + NewTarget func(sarama.ConsumerGroupSession, sarama.ConsumerGroupClaim) (RunnableTarget, error) + type TargetManager struct + 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() + type TargetSyncer struct + func NewSyncer(reg prometheus.Registerer, logger log.Logger, cfg scrapeconfig.Config, ...) (*TargetSyncer, error) + func (c *TargetSyncer) Cleanup(sarama.ConsumerGroupSession) error + func (c *TargetSyncer) ConsumeClaim(session sarama.ConsumerGroupSession, claim sarama.ConsumerGroupClaim) error + func (c *TargetSyncer) Setup(session sarama.ConsumerGroupSession) error + func (ts *TargetSyncer) NewTarget(session sarama.ConsumerGroupSession, claim sarama.ConsumerGroupClaim) (RunnableTarget, error) + func (ts *TargetSyncer) Stop() error + type TopicManager interface + Topics func() ([]string, error) + type XDGSCRAMClient struct + func (x *XDGSCRAMClient) Begin(userName, password, authzID string) (err error) + func (x *XDGSCRAMClient) Done() bool + func (x *XDGSCRAMClient) Step(challenge string) (response string, err error)
Go to main page