NatsOptions is a helper function to group a variadic nats.ProtocolOption into []nats.Option that can be used by either Sender, Consumer or Protocol.

NewMessage wraps an *nats.Msg in a binding.Message.

NewProtocol creates a new NATS protocol.

NewReceiver creates a new protocol.Receiver responsible for receiving messages.

NewSender creates a new protocol.Sender responsible for opening and closing the NATS connection.

NewSenderFromConn creates a new protocol.Sender which leaves responsibility for opening and closing the NATS connection to the caller.

WithQueueSubscriber configures the Consumer to join a queue group when subscribing.

WriteMsg fills the provided writer with the bindings.Message m.

Message implements binding.Message by wrapping an *nats.Msg.

Protocol is a reference implementation for using the CloudEvents binding integration.

QueueSubscriber creates queue subscriptions.

RegularSubscriber creates regular subscriptions.

The Subscriber interface allows us to configure how the subscription is created.

ProtocolOption is the function signature required to be considered an nats.ProtocolOption.