v0.0.0-...-acab7bc Latest Latest

This package is not in the latest version of its module.

Go to latest
Published: Sep 6, 2021 License: Apache-2.0 Imports: 25 Imported by: 0




This section is empty.


View Source
var ExporterMap map[string]*Exporter


View Source
var SHA256 scram.HashGeneratorFcn = func() hash.Hash { return sha256.New() }
View Source
var SHA512 scram.HashGeneratorFcn = func() hash.Hash { return sha512.New() }


func CanReadCertAndKey

func CanReadCertAndKey(certPath, keyPath string) (bool, error)

CanReadCertAndKey returns true if the certificate and key files already exists, otherwise returns false. If lost one of cert and key, returns error.

func NewOpt

func NewOpt(uri, uriZookeeper []string, labels, kafkaVersion string) *kafkaOpts

func SimpleKafkaExporter

func SimpleKafkaExporter(opts kafkaOpts, topicFilter string, groupFilter string, down chan int, clusterInstanceId string)


type Exporter

type Exporter struct {
	// contains filtered or unexported fields

Exporter collects Kafka stats from the given server and exports them using the prometheus metrics package.

func NewExporter

func NewExporter(opts kafkaOpts, topicFilter string, groupFilter string) (*Exporter, error)

NewExporter returns an initialized Exporter.

func (*Exporter) Collect

func (e *Exporter) Collect(ch chan<- prometheus.Metric)

Collect fetches the stats from configured Kafka location and delivers them as Prometheus metrics. It implements prometheus.Collector.

func (*Exporter) Describe

func (e *Exporter) Describe(ch chan<- *prometheus.Desc)

Describe describes all the metrics ever exported by the Kafka exporter. It implements prometheus.Collector.

type XDGSCRAMClient

type XDGSCRAMClient struct {

func (*XDGSCRAMClient) Begin

func (x *XDGSCRAMClient) Begin(userName, password, authzID string) (err error)

func (*XDGSCRAMClient) Done

func (x *XDGSCRAMClient) Done() bool

func (*XDGSCRAMClient) Step

func (x *XDGSCRAMClient) Step(challenge string) (response string, err error)

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL