Categorygithub.com/cloudevents/sdk-go/protocol/amqp/v2
modulepackage
2.15.2
Repository: https://github.com/cloudevents/sdk-go.git
Documentation: pkg.go.dev

# Functions

NewMessage wrap an *amqp.Message in a binding.Message.
NewProtocol creates a new amqp transport.
NewProtocolFromClient creates a new amqp transport.
NewReceiver create a new Receiver which wraps an amqp.Receiver in a binding.Receiver.
NewReceiverProtocol creates a new receiver amqp transport.
NewReceiverProtocolFromClient creates a new receiver amqp transport.
NewSender creates a new Sender which wraps an amqp.Sender in a binding.Sender.
NewSenderProtocol creates a new sender amqp transport.
NewSenderProtocolFromClient creates a new amqp sender transport.
WithConnOpt sets a connection option for amqp.
WithConnSASLPlain sets SASLPlain connection option for amqp.
WithReceiverLinkOption sets a link option for amqp.
WithSenderLinkOption sets a link option for amqp.
WithSessionOpt sets a session option for amqp.
WriteMessage fills the provided amqpMessage with the message m.

# Structs

Message implements binding.Message by wrapping an *amqp.Message.
No description provided by the author

# Type aliases

Option is the function signature required to be considered an amqp.Option.
SenderOptionFunc is the type of amqp.Sender options.