rabbitmq

package module

Go to main page

Versions in this module

v0

v0.2.0

May 6, 2026

Changes in this version

+ func WithConnectionOptionsBackoff(fn func(attempt int) time.Duration) func(options *ConnectionOptions)

+ func WithConnectionOptionsMaxReconnectAttempts(n int) func(options *ConnectionOptions)

+ func WithConnectionOptionsOnConnectionLost(fn func(err error)) func(options *ConnectionOptions)

+ func WithConnectionOptionsOnReconnect(fn func(err error)) func(options *ConnectionOptions)

+ func WithConsumerOptionsOnChannelLost(fn func(err error)) func(*ConsumerOptions)

+ func WithConsumerOptionsOnReconnect(fn func(err error)) func(*ConsumerOptions)

+ func WithPublisherOptionsOnChannelLost(fn func(err error)) func(*PublisherOptions)

+ func WithPublisherOptionsOnReconnect(fn func(err error)) func(*PublisherOptions)

type Conn

+ func (conn *Conn) ReconnectionCount() uint

type ConnectionOptions

+ Backoff func(attempt int) time.Duration

+ MaxReconnectAttempts int

+ OnConnectionLost func(err error)

+ OnReconnect func(err error)

type Consumer

+ func (consumer *Consumer) ReconnectionCount() uint

type ConsumerOptions

+ OnChannelLost func(err error)

+ OnReconnect func(err error)

type Publisher

+ func (publisher *Publisher) ReconnectionCount() uint

type PublisherOptions

+ OnChannelLost func(err error)

+ OnReconnect func(err error)

v0.1.2

Apr 22, 2026

v0.1.1

Jul 30, 2025

Changes in this version

+ const Persistent

+ const Transient

+ func WithConnectionOptionsConfig(cfg Config) func(options *ConnectionOptions)

+ func WithConnectionOptionsLogger(log Logger) func(options *ConnectionOptions)

+ func WithConnectionOptionsLogging(options *ConnectionOptions)

+ func WithConnectionOptionsPreConnectionFunc(preConnFunc func()) func(options *ConnectionOptions)

+ func WithConnectionOptionsReconnectInterval(interval time.Duration) func(options *ConnectionOptions)

+ func WithConsumerOptionsBinding(binding Binding) func(*ConsumerOptions)

+ func WithConsumerOptionsConcurrency(concurrency int) func(*ConsumerOptions)

+ func WithConsumerOptionsConsumerAutoAck(autoAck bool) func(*ConsumerOptions)

+ func WithConsumerOptionsConsumerExclusive(options *ConsumerOptions)

+ func WithConsumerOptionsConsumerName(consumerName string) func(*ConsumerOptions)

+ func WithConsumerOptionsConsumerNoWait(options *ConsumerOptions)

+ func WithConsumerOptionsExchangeArgs(args Table) func(*ConsumerOptions)

+ func WithConsumerOptionsExchangeAutoDelete(options *ConsumerOptions)

+ func WithConsumerOptionsExchangeDeclare(options *ConsumerOptions)

+ func WithConsumerOptionsExchangeDurable(options *ConsumerOptions)

+ func WithConsumerOptionsExchangeInternal(options *ConsumerOptions)

+ func WithConsumerOptionsExchangeKind(kind string) func(*ConsumerOptions)

+ func WithConsumerOptionsExchangeName(name string) func(*ConsumerOptions)

+ func WithConsumerOptionsExchangeNoWait(options *ConsumerOptions)

+ func WithConsumerOptionsExchangeOptions(exchangeOptions ExchangeOptions) func(*ConsumerOptions)

+ func WithConsumerOptionsExchangePassive(options *ConsumerOptions)

+ func WithConsumerOptionsForceShutdown(options *ConsumerOptions)

+ func WithConsumerOptionsLogger(log logger.Logger) func(options *ConsumerOptions)

+ func WithConsumerOptionsLogging(options *ConsumerOptions)

+ func WithConsumerOptionsQOSGlobal(options *ConsumerOptions)

+ func WithConsumerOptionsQOSPrefetch(prefetchCount int) func(*ConsumerOptions)

+ func WithConsumerOptionsQueueArgs(args Table) func(*ConsumerOptions)

+ func WithConsumerOptionsQueueAutoDelete(options *ConsumerOptions)

+ func WithConsumerOptionsQueueDurable(options *ConsumerOptions)

+ func WithConsumerOptionsQueueExclusive(options *ConsumerOptions)

+ func WithConsumerOptionsQueueMessageExpiration(ttl time.Duration) func(*ConsumerOptions)

+ func WithConsumerOptionsQueueNoDeclare(options *ConsumerOptions)

+ func WithConsumerOptionsQueueNoWait(options *ConsumerOptions)

+ func WithConsumerOptionsQueuePassive(options *ConsumerOptions)

+ func WithConsumerOptionsQueueQuorum(options *ConsumerOptions)

+ func WithConsumerOptionsRoutingKey(routingKey string) func(*ConsumerOptions)

+ func WithPublishOptionsAppID(appID string) func(*PublishOptions)

+ func WithPublishOptionsContentEncoding(contentEncoding string) func(*PublishOptions)

+ func WithPublishOptionsContentType(contentType string) func(*PublishOptions)

+ func WithPublishOptionsCorrelationID(correlationID string) func(*PublishOptions)

+ func WithPublishOptionsExchange(exchange string) func(*PublishOptions)

+ func WithPublishOptionsExpiration(expiration string) func(options *PublishOptions)

+ func WithPublishOptionsHeaders(headers Table) func(*PublishOptions)

+ func WithPublishOptionsImmediate(options *PublishOptions)

+ func WithPublishOptionsMandatory(options *PublishOptions)

+ func WithPublishOptionsMessageID(messageID string) func(*PublishOptions)

+ func WithPublishOptionsPersistentDelivery(options *PublishOptions)

+ func WithPublishOptionsPriority(priority uint8) func(*PublishOptions)

+ func WithPublishOptionsReplyTo(replyTo string) func(*PublishOptions)

+ func WithPublishOptionsTimestamp(timestamp time.Time) func(*PublishOptions)

+ func WithPublishOptionsType(messageType string) func(*PublishOptions)

+ func WithPublishOptionsUserID(userID string) func(*PublishOptions)

+ func WithPublisherOptionsConfirm(options *PublisherOptions)

+ func WithPublisherOptionsExchangeArgs(args Table) func(*PublisherOptions)

+ func WithPublisherOptionsExchangeAutoDelete(options *PublisherOptions)

+ func WithPublisherOptionsExchangeDeclare(options *PublisherOptions)

+ func WithPublisherOptionsExchangeDurable(options *PublisherOptions)

+ func WithPublisherOptionsExchangeInternal(options *PublisherOptions)

+ func WithPublisherOptionsExchangeKind(kind string) func(*PublisherOptions)

+ func WithPublisherOptionsExchangeName(name string) func(*PublisherOptions)

+ func WithPublisherOptionsExchangeNoWait(options *PublisherOptions)

+ func WithPublisherOptionsExchangePassive(options *PublisherOptions)

+ func WithPublisherOptionsLogger(log Logger) func(options *PublisherOptions)

+ func WithPublisherOptionsLogging(options *PublisherOptions)

+ type Action int

+ const Ack

+ const Manual

+ const NackDiscard

+ const NackRequeue

+ type Binding struct

+ RoutingKey string

+ type BindingOptions struct

+ Args Table

+ Declare bool

+ NoWait bool

+ type Config amqp.Config

+ type Confirmation struct

+ ReconnectionCount int

+ type Conn struct

+ func NewClusterConn(resolver Resolver, opts ...func(*ConnectionOptions)) (*Conn, error)

+ func NewConn(url string, opts ...func(*ConnectionOptions)) (*Conn, error)

+ func (conn *Conn) Close() error

+ func (conn *Conn) IsClosed() bool

+ type ConnectionOptions struct

+ Config Config

+ Logger Logger

+ PreConnectionFunc func()

+ ReconnectInterval time.Duration

+ type Consumer struct

+ func NewConsumer(conn *Conn, queue string, optionFuncs ...func(*ConsumerOptions)) (*Consumer, error)

+ func (consumer *Consumer) Close()

+ func (consumer *Consumer) CloseWithContext(ctx context.Context)

+ func (consumer *Consumer) Run(handler Handler) error

+ type ConsumerOptions struct

+ CloseGracefully bool

+ Concurrency int

+ ExchangeOptions []ExchangeOptions

+ Logger logger.Logger

+ QOSGlobal bool

+ QOSPrefetch int

+ QueueOptions QueueOptions

+ RabbitConsumerOptions RabbitConsumerOptions

+ type Delivery struct

+ type ExchangeOptions struct

+ Args Table

+ AutoDelete bool

+ Bindings []Binding

+ Declare bool

+ Durable bool

+ Internal bool

+ Kind string

+ Name string

+ NoWait bool

+ Passive bool

+ type Handler func(d Delivery) (action Action)

+ type Logger logger.Logger

+ type PublishOptions struct

+ AppID string

+ ContentEncoding string

+ ContentType string

+ CorrelationID string

+ DeliveryMode uint8

+ Exchange string

+ Expiration string

+ Headers Table

+ Immediate bool

+ Mandatory bool

+ MessageID string

+ Priority uint8

+ ReplyTo string

+ Timestamp time.Time

+ Type string

+ UserID string

+ type Publisher struct

+ func NewPublisher(conn *Conn, optionFuncs ...func(*PublisherOptions)) (*Publisher, error)

+ func (publisher *Publisher) Close()

+ func (publisher *Publisher) NotifyPublish(handler func(p Confirmation))

+ func (publisher *Publisher) NotifyReturn(handler func(r Return))

+ func (publisher *Publisher) Publish(data []byte, routingKeys []string, optionFuncs ...func(*PublishOptions)) error

+ func (publisher *Publisher) PublishWithContext(ctx context.Context, data []byte, routingKeys []string, ...) error

+ func (publisher *Publisher) PublishWithDeferredConfirmWithContext(ctx context.Context, data []byte, routingKeys []string, ...) (PublisherConfirmation, error)

+ type PublisherConfirmation []*amqp.DeferredConfirmation

+ type PublisherOptions struct

+ ConfirmMode bool

+ ExchangeOptions ExchangeOptions

+ Logger Logger

+ type QueueOptions struct

+ Args Table

+ AutoDelete bool

+ Declare bool

+ Durable bool

+ Exclusive bool

+ Name string

+ NoWait bool

+ Passive bool

+ type RabbitConsumerOptions struct

+ Args Table

+ AutoAck bool

+ Exclusive bool

+ Name string

+ NoLocal bool

+ NoWait bool

+ type Resolver = connectionmanager.Resolver

+ type Return struct

+ type StaticResolver struct

+ func NewStaticResolver(urls []string, shuffle bool) *StaticResolver

+ func (r *StaticResolver) Resolve() ([]string, error)

+ type Table map[string]interface

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL