kafka

Documentation

Index

• type Handler
  • func New(ctrl *notification.Controller) *Handler
  • func (c Handler) Cleanup(_ sarama.ConsumerGroupSession) error
  • func (c Handler) ConsumeClaim(sess sarama.ConsumerGroupSession, claim sarama.ConsumerGroupClaim) error
  • func (c Handler) Setup(_ sarama.ConsumerGroupSession) error

Types

type Handler

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

Handler defines a notification Kafka message handler

func New

func New(ctrl *notification.Controller) *Handler

New creates a new notification Kafka message handler

func (Handler) Cleanup

func (c Handler) Cleanup(_ sarama.ConsumerGroupSession) error

func (Handler) ConsumeClaim

func (c Handler) ConsumeClaim(sess sarama.ConsumerGroupSession, claim sarama.ConsumerGroupClaim) error

func (Handler) Setup

func (c Handler) Setup(_ sarama.ConsumerGroupSession) error