Categorygithub.com/grafana/loki/v3clientspkgpromtailtargetskafka
package
3.4.2
Repository: https://github.com/grafana/loki.git
Documentation: pkg.go.dev
Versions
2
Dependencies
29
Dependents
2
Files
853 SLOC

# Functions

NewSyncer creates TargetSyncer.
NewSyncerFromScrapeConfig creates TargetSyncer from scrape config.
NewTargetManager creates a new Kafka managers.

# Variables

copied from https://github.com/Shopify/sarama/blob/44627b731c60bb90efe25573e7ef2b3f8df3fa23/examples/sasl_scram_client/scram_client.go.
copied from https://github.com/Shopify/sarama/blob/44627b731c60bb90efe25573e7ef2b3f8df3fa23/examples/sasl_scram_client/scram_client.go.

# Structs

TargetManager manages a series of kafka targets.
TargetSyncerConfig contains specific TargetSyncer configuration.
XDGSCRAMClient implements sarama.SCRAMClient.

# Interfaces

MessageParser defines parsing for each incoming message.