Documentation ¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type DefaultResponseHandler ¶ added in v0.0.2
type DefaultResponseHandler struct{}
func (*DefaultResponseHandler) OnError ¶ added in v0.0.2
func (drh *DefaultResponseHandler) OnError(ctx *ResponseHandlerContext)
func (*DefaultResponseHandler) OnSuccess ¶ added in v0.0.2
func (drh *DefaultResponseHandler) OnSuccess(_ *ResponseHandlerContext)
type ResponseHandler ¶
type ResponseHandler interface { OnSuccess(ctx *ResponseHandlerContext) OnError(ctx *ResponseHandlerContext) }
type ResponseHandlerContext ¶
type ResponseHandlerContext struct { Message *kafka.Message Err error }
Click to show internal directories.
Click to hide internal directories.