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 ¶
func CanReadCertAndKey ¶
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 (*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 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
Source Files
Click to show internal directories.
Click to hide internal directories.