sarama

Documentation

Index

• type Handler
  • func New(c sk.ConsumerConfig, options ...OptionFunc) (*Handler, error)
  • func (h *Handler) Receive() <-chan sk.Message
  • func (h *Handler) Run() error
  • func (h *Handler) Stop()
• type Logger
• type Message
  • func (m Message) Offset() int64
  • func (m Message) Partition() int32
  • func (m Message) Topic() string
  • func (m Message) Value() []byte
• type OptionFunc
  • func WithLogger(log Logger) OptionFunc

Types

type Handler

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

func New

func New(c sk.ConsumerConfig, options ...OptionFunc) (*Handler, error)

func (*Handler) Receive

func (h *Handler) Receive() <-chan sk.Message

func (*Handler) Run

func (h *Handler) Run() error

func (*Handler) Stop

func (h *Handler) Stop()

type Logger

type Logger interface {
	Infof(string, ...interface{})
	Errorf(string, ...interface{})
}

type Message

type Message struct {
	*sarama.ConsumerMessage
}

func (Message) Offset

func (m Message) Offset() int64

func (Message) Partition

func (m Message) Partition() int32

func (Message) Topic

func (m Message) Topic() string

func (Message) Value

func (m Message) Value() []byte

type OptionFunc

type OptionFunc func(*Handler) error

func WithLogger

func WithLogger(log Logger) OptionFunc