Documentation
¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func NewErrorHandler ¶
func NewErrorHandler(errHandler ErrorHandlerFunc, next shuttle.HandlerFunc) shuttle.HandlerFunc
An error handler that continues the normal shuttle.HandlerFunc handler chain.
Types ¶
type ErrorHandler ¶
type ErrorHandler interface {
Handle(ctx context.Context, settler shuttle.MessageSettler, message *azservicebus.ReceivedMessage) *errors.AsyncError
}
TODO(mheberling): Separate interface and error handlers into different files. ErrorHandler interface that returns an error. Required for any error handling accross handlers.
type ErrorHandlerFunc ¶
type ErrorHandlerFunc func(ctx context.Context, settler shuttle.MessageSettler, message *azservicebus.ReceivedMessage) *errors.AsyncError
func NewErrorReturnHandler ¶
func NewErrorReturnHandler(errHandler ErrorHandlerFunc, next shuttle.HandlerFunc) ErrorHandlerFunc
An error handler that provides the error to the parent handler for logging.
func (ErrorHandlerFunc) Handle ¶
func (f ErrorHandlerFunc) Handle(ctx context.Context, settler shuttle.MessageSettler, message *azservicebus.ReceivedMessage) *errors.AsyncError
Source Files
Click to show internal directories.
Click to hide internal directories.