Versions in this module Expand all Collapse all v2 v2.6.0 Apr 26, 2021 Changes in this version + var ResultACK = NewReceipt(true, "") + var ResultAs = errors.As + var ResultIs = errors.Is + var ResultNACK = NewReceipt(false, "") + func IsACK(target Result) bool + func IsNACK(target Result) bool + func IsUndelivered(target Result) bool + type Closer interface + Close func(ctx context.Context) error + type ErrTransportMessageConversion struct + func NewErrTransportMessageConversion(transport, message string, handled, fatal bool) *ErrTransportMessageConversion + func (e *ErrTransportMessageConversion) Error() string + func (e *ErrTransportMessageConversion) Handled() bool + func (e *ErrTransportMessageConversion) IsFatal() bool + type Opener interface + OpenInbound func(ctx context.Context) error + type Receipt struct + ACK bool + Err error + func (e *Receipt) Error() string + func (e *Receipt) Is(target error) bool + func (e *Receipt) Unwrap() error + type ReceiveCloser interface + type Receiver interface + Receive func(ctx context.Context) (binding.Message, error) + type Requester interface + Request func(ctx context.Context, m binding.Message, transformers ...binding.Transformer) (binding.Message, error) + type RequesterCloser interface + type Responder interface + Respond func(ctx context.Context) (binding.Message, ResponseFn, error) + type ResponderCloser interface + type ResponseFn func(ctx context.Context, m binding.Message, r Result, ...) error + type Result error + func NewReceipt(ack bool, messageFmt string, args ...interface{}) Result + func NewResult(messageFmt string, args ...interface{}) Result + type SendCloser interface + type Sender interface + Send func(ctx context.Context, m binding.Message, transformers ...binding.Transformer) error