kafka

Documentation

Index

• type Option
  • func WithLogger(logger loglib.Logger) Option
• type Reader
  • func NewWALReader(kafkaReader kafkaReader, processRecord payloadProcessor, opts ...Option) (*Reader, error)
  • func (r *Reader) Close() error
  • func (r *Reader) Listen(ctx context.Context) error

Types

type Option

type Option func(*Reader)

func WithLogger

func WithLogger(logger loglib.Logger) Option

type Reader

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

Reader is a kafka reader that listens to wal events.

func NewWALReader

func NewWALReader(kafkaReader kafkaReader, processRecord payloadProcessor, opts ...Option) (*Reader, error)

NewReader returns a kafka reader that listens to wal events and calls the processor on input.

func (*Reader) Close

func (r *Reader) Close() error

func (*Reader) Listen

func (r *Reader) Listen(ctx context.Context) error