Documentation ¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type DecoderFunc ¶
type DecoderFunc func(ctx context.Context, message *sarama.ConsumerMessage) (interface{}, error)
type EncoderFunc ¶
type HandlerFunc ¶
type HandlerFunc func(ctx context.Context, message *sarama.ConsumerMessage) error
type MiddlewareFunc ¶
type MiddlewareFunc func(next HandlerFunc) HandlerFunc
type Option ¶
type Option interface {
Apply(o *options)
}
func WithDecoder ¶
func WithEncoder ¶
func WithErrorHandler ¶
func WithMiddleware ¶
func WithMiddleware(middlewares ...MiddlewareFunc) Option
Click to show internal directories.
Click to hide internal directories.