MessageMetadataFrom extracts the STAN message metadata from the provided ctx.

MetadataContextDecorator returns an inbound context decorator which adds STAN message metadata to the current context.

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

NewProtocol creates a new STAN protocol including managing the lifecycle of the connection.

NewProtocolFromConn creates a new STAN protocol but leaves managing the lifecycle of the connection up to the caller.

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

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

StanOptions is a helper function to group a variadic stan.Option into []stan.Option.

WithQueueSubscriber configures the transport to create a queue subscription instead of a standard subscription.

WithSubscriptionOptions sets options to configure the STAN subscription.

WithUnsubscribeOnClose configures the Consumer to unsubscribe when OpenInbound context is cancelled or when Consumer.Close() is invoked.

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

Consumer is responsible for managing STAN subscriptions and makes messages available via the Receiver interface.

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

MsgMetadata holds metadata of a received *stan.Msg.

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

QueueSubscriber creates queue subscriptions.

Receiver implements protocol.Receiver for STAN subscriptions.

RegularSubscriber creates regular subscriptions.

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