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

rabbitgo

package module

Go to main page

Versions in this module

v0

v0.1.2

May 21, 2019

Changes in this version

type Connection

+ IsBlocked bool

+ IsConnected bool

+ func (c *Connection) ExchangeDeclare(exchange *Exchange) error

type ConsumerConfig

+ MaxDeliveries int

type Delivery

+ func (d *Delivery) Proto(message interface{})

+ type ErrorTimeout struct

+ Queue string

+ Timeout time.Duration

+ func (e ErrorTimeout) Error() string

type ProducerConfig

+ MaxDeliveries int

v0.1.1

Sep 14, 2016

v0.1.0

Sep 9, 2016

Changes in this version

+ type BindingConfig struct

+ Args amqp.Table

+ NoWait bool

+ RoutingKey string

+ type Config struct

+ Host string

+ Password string

+ Port int

+ Username string

+ Vhost string

+ type Connection struct

+ func NewConnection(c *Config) (*Connection, error)

+ func (c *Connection) Close()

+ func (c *Connection) Dial() error

+ func (c *Connection) NewConsumer(e *Exchange, q *Queue, bc *BindingConfig, cc *ConsumerConfig) (*Consumer, error)

+ func (c *Connection) NewProducer(pc *ProducerConfig) (*Producer, error)

+ func (c *Connection) Publish(exchange, key string, mandatory, immediate bool, msg *amqp.Publishing) error

+ type Consumer struct

+ func (c *Consumer) Consume(handler func(delivery *Delivery)) error

+ func (c *Consumer) ConsumeRPC(handler func(delivery *Delivery)) error

+ func (c *Consumer) Deliveries() <-chan amqp.Delivery

+ func (c *Consumer) Get(handler func(delivery *Delivery)) error

+ func (c *Consumer) QOS(messageCount int) error

+ func (c *Consumer) Shutdown() error

+ type ConsumerConfig struct

+ Args amqp.Table

+ AutoAck bool

+ Exclusive bool

+ NoLocal bool

+ NoWait bool

+ PrefetchCount int

+ PrefetchSize int

+ Tag string

+ Timeout int

+ type Delivery struct

+ AckError error

+ Delegated bool

+ Response *response

+ func (d *Delivery) AckOrSkip(multiple bool) error

+ func (d *Delivery) Data(data []byte, contentType string)

+ func (d *Delivery) Delegate(ack string, options ...bool) *amqp.Publishing

+ func (d *Delivery) IsAutoAck() bool

+ func (d *Delivery) PreAck(multiple bool)

+ func (d *Delivery) RejectOrSkip(requeue bool) error

+ type Exchange struct

+ Args amqp.Table

+ AutoDelete bool

+ Durable bool

+ Internal bool

+ Name string

+ NoWait bool

+ Type string

+ type Producer struct

+ func (p *Producer) NotifyPublish(confirmer func(message amqp.Confirmation))

+ func (p *Producer) NotifyReturn(notifier func(message amqp.Return))

+ func (p *Producer) Publish(publishing *amqp.Publishing) error

+ func (p *Producer) PublishRPC(publishing *amqp.Publishing, handler func(delivery *Delivery)) error

+ func (p *Producer) Shutdown() error

+ type ProducerConfig struct

+ Exchange string

+ Immediate bool

+ Mandatory bool

+ RoutingKey string

+ Tag string

+ Timeout int

+ type Publishing struct

+ AppId string

+ Body []byte

+ ContentEncoding string

+ ContentType string

+ CorrelationId string

+ DeliveryMode uint8

+ Expiration string

+ Headers map[string]interface{}

+ MessageId string

+ Priority uint8

+ ReplyTo string

+ Timestamp time.Time

+ Type string

+ UserId string

+ type Queue struct

+ Args amqp.Table

+ AutoDelete bool

+ Durable bool

+ Exclusive bool

+ Name string

+ NoWait bool