listenhandler

Documentation

Index

• Variables
• type ListenHandler
  • func New(kfkConn sarama.Client, transmitter Transmitter) (*ListenHandler, error)
  • func (lh *ListenHandler) Close()
  • func (lh *ListenHandler) Listen(topic string, partition int32, offset int64) error
  • func (lh *ListenHandler) Unlisten(topic string, partition int32) error
• type Stream
• type Transmitter

Variables

var ErrAlreadyListening = errors.New("Already listening to stream")

var ErrListenHandlerClosed = errors.New("Listen handler had been closed")

var ErrListenerQuit = errors.New("Listener exited unexpectedly; offset out of range?")

var ErrNotListening = errors.New("Not listening to stream")

Types

type ListenHandler

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

func New

func New(kfkConn sarama.Client, transmitter Transmitter) (*ListenHandler, error)

func (*ListenHandler) Close

func (lh *ListenHandler) Close()

func (*ListenHandler) Listen

func (lh *ListenHandler) Listen(topic string, partition int32, offset int64) error

func (*ListenHandler) Unlisten

func (lh *ListenHandler) Unlisten(topic string, partition int32) error

type Stream

type Stream struct {
	Topic     string
	Partition int32
}

type Transmitter

type Transmitter interface {
	Transmit(key, val []byte, topic string, partition int32, offset int64)
	Close()
}