Versions in this module Expand all Collapse all v2 v2.0.1 Jun 16, 2021 v2.0.0 Jun 16, 2021 Changes in this version + var SHA256 scram.HashGeneratorFcn = func() hash.Hash + var SHA512 scram.HashGeneratorFcn = func() hash.Hash + func CanReadCertAndKey(certPath, keyPath string) (bool, error) + type Exporter struct + func New(logger log.Logger, opts Options, topicFilter, groupFilter string) (*Exporter, error) + func (e *Exporter) Close() + func (e *Exporter) Collect(ch chan<- prometheus.Metric) + func (e *Exporter) Describe(ch chan<- *prometheus.Desc) + func (e *Exporter) RunPruner(quit chan struct{}) + type Options struct + AllowConcurrent bool + KafkaVersion string + Labels string + MaxOffsets int + MetadataRefreshInterval string + PruneIntervalSeconds int + SaslMechanism string + SaslPassword string + SaslUsername string + TlsCAFile string + TlsCertFile string + TlsInsecureSkipTLSVerify bool + TlsKeyFile string + Uri []string + UriZookeeper []string + UseSASL bool + UseSASLHandshake bool + UseTLS bool + UseZooKeeperLag bool + 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)