saramax

Documentation

Index

• type BatchHandler
  • func NewBatchHandler[T any](fn func(msgs []*sarama.ConsumerMessage, event T) error, l logger2.Logger) *BatchHandler[T]
  • func (h *BatchHandler[T]) Cleanup(session sarama.ConsumerGroupSession) error
  • func (h *BatchHandler[T]) ConsumeClaim(session sarama.ConsumerGroupSession, claim sarama.ConsumerGroupClaim) error
  • func (h *BatchHandler[T]) Setup(session sarama.ConsumerGroupSession) error
• type Handler
  • func NewHandler[T any](fn func(msg *sarama.ConsumerMessage, event T) error, l logger2.Logger) *Handler[T]
  • func (h *Handler[T]) Cleanup(session sarama.ConsumerGroupSession) error
  • func (h *Handler[T]) ConsumeClaim(session sarama.ConsumerGroupSession, claim sarama.ConsumerGroupClaim) error
  • func (h *Handler[T]) Setup(session sarama.ConsumerGroupSession) error

Types

type BatchHandler

type BatchHandler[T any] struct {
	// contains filtered or unexported fields
}

func NewBatchHandler

func NewBatchHandler[T any](
	fn func(msgs []*sarama.ConsumerMessage, event T) error,
	l logger2.Logger) *BatchHandler[T]

func (*BatchHandler[T]) Cleanup

func (h *BatchHandler[T]) Cleanup(session sarama.ConsumerGroupSession) error

func (*BatchHandler[T]) ConsumeClaim

func (h *BatchHandler[T]) ConsumeClaim(session sarama.ConsumerGroupSession, claim sarama.ConsumerGroupClaim) error

func (*BatchHandler[T]) Setup

func (h *BatchHandler[T]) Setup(session sarama.ConsumerGroupSession) error

type Handler

type Handler[T any] struct {
	// contains filtered or unexported fields
}

func NewHandler

func NewHandler[T any](
	fn func(msg *sarama.ConsumerMessage, event T) error,
	l logger2.Logger) *Handler[T]

func (*Handler[T]) Cleanup

func (h *Handler[T]) Cleanup(session sarama.ConsumerGroupSession) error

func (*Handler[T]) ConsumeClaim

func (h *Handler[T]) ConsumeClaim(session sarama.ConsumerGroupSession, claim sarama.ConsumerGroupClaim) error

func (*Handler[T]) Setup

func (h *Handler[T]) Setup(session sarama.ConsumerGroupSession) error