Categorygithub.com/sciclon2/kafka-lag-gopkgstructs
package
3.0.0+incompatible
Repository: https://github.com/sciclon2/kafka-lag-go.git
Documentation: pkg.go.dev
Overview
Versions
3
Dependencies
2
Dependents
17
Files
116 SLOC

# Structs

No description provided by the author
HealthStatus represents the structure of the health check response.
No description provided by the author
SaramaBrokerWrapper wraps sarama.Broker and implements KafkaBrokerInterface.
SaramaKafkaAdmin wraps sarama.ClusterAdmin and implements the KafkaAdmin interface.
SaramaKafkaClient wraps sarama.Client and implements the KafkaClient interface.
No description provided by the author

# Interfaces

KafkaAdmin is an interface that wraps sarama.ClusterAdmin methods.
KafkaBrokerInterface abstracts sarama.Broker for easier testing.
KafkaClient is an interface that wraps sarama.Client methods.