Why Go
- Case Studies
  
  Common problems companies solve with Go
- Use Cases
  
  Stories about how and why companies use Go
- Security
  
  How Go can help keep you secure by default
Learn
Docs
- Effective Go
  
  Tips for writing clear, performant, and idiomatic Go code
- Go User Manual
  
  A complete introduction to building software with Go
- Standard library
  
  Reference documentation for Go's standard library
- Release Notes
  
  Learn what's new in each Go release
Packages
Community
- Recorded Talks
  
  Videos from prior events
- Meetups
  
  Meet other local Go developers
- Conferences
  
  Learn and network with Go developers from around the world
- Go blog
  
  The Go project's official blog.
- Go project
  
  Get help and stay informed from Go
- Get connected

options

package

Go to main page

Versions in this module

v1

v1.11.0

Oct 14, 2025

v1.10.0

Dec 27, 2024

v1.9.0

Aug 11, 2024

v1.8.2

Jun 22, 2024

v1.8.1

Nov 19, 2023

v1.8.0

Aug 8, 2023

Changes in this version

+ var DefaultConnectionOptions = ConnectionOptions

+ type BindOptions struct

+ Args map[string]interface{}

+ NoWait bool

+ RoutingKey string

+ type ConnectionOption func(*ConnectionOptions)

+ func WithURI(uri string) ConnectionOption

+ type ConnectionOptions struct

+ Config *amqp091.Config

+ Host string

+ Password string

+ Port int

+ Scheme string

+ URI string

+ Username string

+ Vhost string

+ func NewConnectionOptions(opts ...ConnectionOption) (*ConnectionOptions, error)

+ type ConsumerOption func(*ConsumerOptions)

+ func WithConsumerOptionConcurrency(concurrency int) ConsumerOption

+ func WithConsumerOptionConsumerArgs(args map[string]interface{}) ConsumerOption

+ func WithConsumerOptionConsumerAutoAck(autoAck bool) ConsumerOption

+ func WithConsumerOptionConsumerExclusive(exclusive bool) ConsumerOption

+ func WithConsumerOptionConsumerName(consumerName string) ConsumerOption

+ func WithConsumerOptionConsumerNoLocal(noLocal bool) ConsumerOption

+ func WithConsumerOptionConsumerNoWait(noWait bool) ConsumerOption

+ func WithConsumerOptionConsumerQueue(queue string) ConsumerOption

+ func WithConsumerOptionQOSGlobal(global bool) ConsumerOption

+ func WithConsumerOptionQOSPrefetch(prefetchCount int) ConsumerOption

+ func WithConsumerOptionQOSPrefetchSize(prefetchSize int) ConsumerOption

+ type ConsumerOptions struct

+ Concurrency int

+ ConsumerArgs map[string]interface{}

+ ConsumerAutoAck bool

+ ConsumerExclusive bool

+ ConsumerName string

+ ConsumerNoLocal bool

+ ConsumerNoWait bool

+ ConsumerQueue string

+ QOSGlobal bool

+ QOSPrefetchCount int

+ QOSPrefetchSize int

+ func NewConsumerOptions(opts ...ConsumerOption) *ConsumerOptions

+ type ExchangeOptions struct

+ Args map[string]interface{}

+ AutoDelete bool

+ Durable bool

+ Internal bool

+ Kind string

+ Name string

+ NoWait bool

+ type PublishOption func(*PublishOptions)

+ func WithPublishOptionAppID(appID string) PublishOption

+ func WithPublishOptionContentEncoding(contentEncoding string) PublishOption

+ func WithPublishOptionContentType(contentType string) PublishOption

+ func WithPublishOptionCorrelationID(correlationID string) PublishOption

+ func WithPublishOptionDeliveryMode(deliveryMode uint8) PublishOption

+ func WithPublishOptionExpiration(expiration string) PublishOption

+ func WithPublishOptionHeaders(headers amqp091.Table) PublishOption

+ func WithPublishOptionImmediate(immediate bool) PublishOption

+ func WithPublishOptionMandatory(mandatory bool) PublishOption

+ func WithPublishOptionMaxRetry(MaxRetry uint64) PublishOption

+ func WithPublishOptionMessageID(messageID string) PublishOption

+ func WithPublishOptionMsgExchange(msgExchange string) PublishOption

+ func WithPublishOptionMsgRoutingKey(msgRoutingKey string) PublishOption

+ func WithPublishOptionPriority(priority uint8) PublishOption

+ func WithPublishOptionReplyTo(replyTo string) PublishOption

+ func WithPublishOptionTimestamp(timestamp time.Time) PublishOption

+ func WithPublishOptionType(typ string) PublishOption

+ func WithPublishOptionUserID(userID string) PublishOption

+ type PublishOptions struct

+ Immediate bool

+ Mandatory bool

+ MaxRetry uint64

+ MsgExchange string

+ MsgRoutingKey string

+ func NewPublishOption(opts ...PublishOption) *PublishOptions

+ type QueueOptions struct

+ Args map[string]interface{}

+ AutoDelete bool

+ Durable bool

+ Exclusive bool

+ Name string

+ NoWait bool