Documentation ¶ Index ¶ Variables type Handler func New(handlerFunc interface{}) Handler func (m Handler) Handle(ctx context.Context, msg []byte) error type List func (l List) AddHandler(messageType string, handler Handler) func (l List) Handle(ctx context.Context, message *sarama.ConsumerMessage) error type Unmarshaller Constants ¶ This section is empty. Variables ¶ View Source var ErrNotFound = errors.New("handler not found") Functions ¶ This section is empty. Types ¶ type Handler ¶ type Handler struct { // contains filtered or unexported fields } func New ¶ func New(handlerFunc interface{}) Handler func (Handler) Handle ¶ func (m Handler) Handle(ctx context.Context, msg []byte) error type List ¶ type List map[string][]Handler func (List) AddHandler ¶ func (l List) AddHandler(messageType string, handler Handler) func (List) Handle ¶ func (l List) Handle(ctx context.Context, message *sarama.ConsumerMessage) error type Unmarshaller ¶ type Unmarshaller interface { UnmarshallKFK([]byte) error } Source Files ¶ View all Source files message_handler.go Directories ¶ Show internal Expand all Path Synopsis guard Click to show internal directories. Click to hide internal directories.