Documentation ¶
Index ¶
- func ContextFromDelivery(msg amqp091.Delivery) context.Context
- type Channel
- func (ch *Channel) Consume(queue, consumer string, autoAck, exclusive, noLocal, noWait bool, ...) (<-chan amqp091.Delivery, error)
- func (ch *Channel) Get(queue string, autoAck bool) (msg amqp091.Delivery, ok bool, err error)
- func (ch *Channel) PublishWithContext(ctx context.Context, exchange, key string, mandatory, immediate bool, ...) error
- func (ch *Channel) PublishWithDeferredConfirmWithContext(ctx context.Context, exchange, key string, mandatory, immediate bool, ...) (*amqp091.DeferredConfirmation, error)
- type Option
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func ContextFromDelivery ¶
Types ¶
type Channel ¶
type Channel struct { *amqp091.Channel // contains filtered or unexported fields }
func NewChannel ¶
func (*Channel) PublishWithContext ¶
type Option ¶
type Option func(*config)
Option sets optional config properties.
func WithPropagators ¶
func WithPropagators(propagators propagation.TextMapPropagator) Option
WithPropagators sets the propagators.
func WithTracerProvider ¶
func WithTracerProvider(provider trace.TracerProvider) Option
WithTracerProvider sets the tracer provider.
Source Files ¶
Click to show internal directories.
Click to hide internal directories.