Documentation
¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
View Source
var SHA256 scram.HashGeneratorFcn = func() hash.Hash { return sha256.New() }
View Source
var SHA512 scram.HashGeneratorFcn = func() hash.Hash { return sha512.New() }
Functions ¶
This section is empty.
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 NewExporter ¶
func NewExporter(opts KafkaOpts, topicFilter string, topicExclude string, groupFilter string, groupExclude string) (*Exporter, error)
NewExporter returns an initialized Exporter.
func (*Exporter) CloseClient ¶
func (e *Exporter) CloseClient()
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.
type KafkaOpts ¶
type KafkaOpts struct {
Namespace string
Uri []string
UseSASL bool
UseSASLHandshake bool
SaslUsername string
SaslPassword string
SaslMechanism string
SaslDisablePAFXFast bool
UseTLS bool
TlsServerName string
TlsCAFile string
TlsCertFile string
TlsKeyFile string
ServerUseTLS bool
ServerMutualAuthEnabled bool
ServerTlsCAFile string
ServerTlsCertFile string
ServerTlsKeyFile string
TlsInsecureSkipTLSVerify bool
KafkaVersion string
UseZooKeeperLag bool
UriZookeeper []string
Labels string
ServiceName string
KerberosConfigPath string
Realm string
KeyTabPath string
KerberosAuthType string
OffsetShowAll bool
TopicWorkers 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
Source Files
Click to show internal directories.
Click to hide internal directories.