exporter

Documentation

Index

• Variables
• func CanReadCertAndKey(certPath, keyPath string) (bool, error)
• type Exporter
  • 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
• type XDGSCRAMClient
  • 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)

Variables

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

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

Functions

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.

Types

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 New

func New(logger log.Logger, opts Options, topicFilter, groupFilter string) (*Exporter, error)

New returns an initialized Exporter.

func (*Exporter) Close

func (e *Exporter) Close()

func (*Exporter) Collect

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

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.

func (*Exporter) RunPruner

func (e *Exporter) RunPruner(quit chan struct{})

Run iMap.Prune() on an interval (default 30 seconds). A new client is created to avoid an issue where the client may be closed before Prune attempts to use it.

type Options

type Options struct {
	Uri                      []string
	UseSASL                  bool
	UseSASLHandshake         bool
	SaslUsername             string
	SaslPassword             string
	SaslMechanism            string
	UseTLS                   bool
	TlsCAFile                string
	TlsCertFile              string
	TlsKeyFile               string
	TlsInsecureSkipTLSVerify bool
	KafkaVersion             string
	UseZooKeeperLag          bool
	UriZookeeper             []string
	Labels                   string
	MetadataRefreshInterval  string
	AllowConcurrent          bool
	MaxOffsets               int
	PruneIntervalSeconds     int
}

type XDGSCRAMClient

type XDGSCRAMClient struct {
	*scram.Client
	*scram.ClientConversation
	scram.HashGeneratorFcn
}

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)