Documentation ¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func GetKafkaAccessEnv ¶
Types ¶
type ConsumerImpl ¶
type ConsumerImpl struct {
// contains filtered or unexported fields
}
func (*ConsumerImpl) Cleanup ¶
func (consumer *ConsumerImpl) Cleanup(session sarama.ConsumerGroupSession) error
Cleanup runs at the end of a session, once all ConsumeClaim goroutines have exited.
func (*ConsumerImpl) ConsumeClaim ¶
func (consumer *ConsumerImpl) ConsumeClaim(session sarama.ConsumerGroupSession, claim sarama.ConsumerGroupClaim) error
func (*ConsumerImpl) Setup ¶
func (consumer *ConsumerImpl) Setup(session sarama.ConsumerGroupSession) error
Setup runs at the beginning of a session before ConsumeClaim.
type OpLogger ¶
type OpLogger struct {
// contains filtered or unexported fields
}
func NewOpLogger ¶
func (*OpLogger) SetUpConsumer ¶
func (*OpLogger) SetUpProducer ¶
func (*OpLogger) SyncAddOpLog ¶
func (olr *OpLogger) SyncAddOpLog(oplog *pb_api.OpLogEntry)
Click to show internal directories.
Click to hide internal directories.