Module amqp implements an AMQP binding using pack.ag/amqp module */.

Package nats implements the CloudEvent transport implementation using NATS.

Package test provides re-usable functions for binding tests.

NewErrMessageEncodingUnknown makes a new ErrMessageEncodingUnknown.

As finds the first error in err's chain that matches target, and if so, sets target to that error value and returns true.

Is reports whether any error in err's chain matches target.

ErrTransportMessageConversion is an error produced when the transport message can not be converted.

Closer is the common interface for things that can be closed.

Opener is the common interface for things that need to be opened.

ReceiveCloser is a Receiver that can be closed.

Receiver receives messages.

Requester sends a message and receives a response Optional interface that may be implemented by protocols that support request/response correlation.

RequesterCloser is a Requester that can be closed.

Responder receives messages and is given a callback to respond.

ResponderCloser is a Responder that can be closed.

SendCloser is a Sender that can be closed.

Sender sends messages.

ResponseFn is the function callback provided from Responder.Respond to allow for a receiver to "reply" to a message it receives.

Result leverages go's 1.13 error wrapping.