kafka

Documentation

Index

• func Config(cfg configs.Configuration) *sarama.Config
• func NewWorkQueueConsumer(_ configs.Configuration, topicHandlers map[enums.Daemon]definition.Consumer) error
• func NewWorkQueueProducer(_ configs.Configuration, _ map[enums.Daemon]definition.Consumer) (definition.WorkQueueProducer, error)
• type ConsumerGroupHandler
  • func (h *ConsumerGroupHandler) Cleanup(session sarama.ConsumerGroupSession) error
  • func (h *ConsumerGroupHandler) ConsumeClaim(session sarama.ConsumerGroupSession, claim sarama.ConsumerGroupClaim) error
  • func (h *ConsumerGroupHandler) Setup(session sarama.ConsumerGroupSession) error
• type MessageWrapper

Functions

func Config

func Config(cfg configs.Configuration) *sarama.Config

Config ...

func NewWorkQueueConsumer

func NewWorkQueueConsumer(_ configs.Configuration, topicHandlers map[enums.Daemon]definition.Consumer) error

NewWorkQueueConsumer ...

func NewWorkQueueProducer

func NewWorkQueueProducer(_ configs.Configuration, _ map[enums.Daemon]definition.Consumer) (definition.WorkQueueProducer, error)

NewWorkQueueProducer ...

Types

type ConsumerGroupHandler

type ConsumerGroupHandler struct {
	// contains filtered or unexported fields
}

ConsumerGroupHandler ...

func (*ConsumerGroupHandler) Cleanup

func (h *ConsumerGroupHandler) Cleanup(session sarama.ConsumerGroupSession) error

Cleanup ...

func (*ConsumerGroupHandler) ConsumeClaim

func (h *ConsumerGroupHandler) ConsumeClaim(session sarama.ConsumerGroupSession, claim sarama.ConsumerGroupClaim) error

ConsumeClaim ...

func (*ConsumerGroupHandler) Setup

func (h *ConsumerGroupHandler) Setup(session sarama.ConsumerGroupSession) error

Setup ...

type MessageWrapper

type MessageWrapper struct {
	Times   int
	Payload []byte
}

MessageWrapper ...