Versions in this module Expand all Collapse all v2 v2.0.0 Jun 14, 2023 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 MessageParser interface + Parse func(message *sarama.ConsumerMessage, labels model.LabelSet, ...) ([]api.Entry, error) + type RunnableTarget interface + type Target struct + func NewTarget(logger log.Logger, session sarama.ConsumerGroupSession, ...) *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(ctx context.Context, reg prometheus.Registerer, logger log.Logger, ...) (*TargetSyncer, error) + func NewSyncerFromScrapeConfig(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(_ sarama.ConsumerGroupSession) error + func (ts *TargetSyncer) ActiveTargets() []target.Target + func (ts *TargetSyncer) DroppedTargets() []target.Target + func (ts *TargetSyncer) NewTarget(session sarama.ConsumerGroupSession, claim sarama.ConsumerGroupClaim) (RunnableTarget, error) + func (ts *TargetSyncer) Stop() error + type TargetSyncerConfig struct + GroupID string + Labels model.LabelSet + RelabelConfigs []*relabel.Config + UseIncomingTimestamp bool + 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)