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

cony

package module

Go to main page

Versions in this module

v0

v0.3.3

Nov 25, 2019

Changes in this version

type Client

+ func (c *Client) ComsumeDeclare(d []Declaration)

+ func (c *Client) PublishDeclare(d []Declaration)

type Declaration

+ func DeclareConfirm(noWait bool) Declaration

+ func DeclareNotifyPublish(confirm chan amqp.Confirmation) Declaration

+ func DeclareNotifyReturn(rc chan amqp.Return) Declaration

type Declarer

+ Confirm func(noWait bool) error

+ NotifyPublish func(confirm chan amqp.Confirmation) chan amqp.Confirmation

+ NotifyReturn func(c chan amqp.Return) chan amqp.Return

type PublisherOpt

+ func PublishingMandatory(m bool) PublisherOpt

v0.3.2

Dec 21, 2016

Changes in this version

type Publisher

+ func (p *Publisher) PublishWithRoutingKey(pub amqp.Publishing, key string) error

v0.3.1

Nov 23, 2016

v0.3.0

Nov 22, 2016

Changes in this version

type Binding

+ Args amqp.Table

type ClientOpt

+ func Config(config amqp.Config) ClientOpt

type Exchange

+ Args amqp.Table

type Queue

+ Args amqp.Table

v0.2.0

Feb 24, 2016

Changes in this version

+ var ErrNoConnection = errors.New("No connection available")

+ var ErrPublisherDead = errors.New("Publisher is dead")

+ type BackoffPolicy struct

+ func (b BackoffPolicy) Backoff(n int) time.Duration

+ type Backoffer interface

+ Backoff func(int) time.Duration

+ var DefaultBackoff Backoffer = BackoffPolicy{ ... }

+ type Binding struct

+ Exchange Exchange

+ Key string

+ Queue *Queue

+ type Client struct

+ func NewClient(opts ...ClientOpt) *Client

+ func (c *Client) Blocking() <-chan amqp.Blocking

+ func (c *Client) Close()

+ func (c *Client) Consume(cons *Consumer)

+ func (c *Client) Declare(d []Declaration)

+ func (c *Client) Errors() <-chan error

+ func (c *Client) Loop() bool

+ func (c *Client) Publish(pub *Publisher)

+ type ClientOpt func(*Client)

+ func Backoff(bo Backoffer) ClientOpt

+ func BlockingChan(blockingChan chan amqp.Blocking) ClientOpt

+ func ErrorsChan(errChan chan error) ClientOpt

+ func URL(addr string) ClientOpt

+ type Consumer struct

+ func NewConsumer(q *Queue, opts ...ConsumerOpt) *Consumer

+ func (c *Consumer) Cancel()

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

+ func (c *Consumer) Errors() <-chan error

+ type ConsumerOpt func(*Consumer)

+ func AutoAck() ConsumerOpt

+ func AutoTag() ConsumerOpt

+ func Exclusive() ConsumerOpt

+ func NoLocal() ConsumerOpt

+ func Qos(count int) ConsumerOpt

+ func Tag(tag string) ConsumerOpt

+ type Declaration func(Declarer) error

+ func DeclareBinding(b Binding) Declaration

+ func DeclareExchange(e Exchange) Declaration

+ func DeclareQueue(q *Queue) Declaration

+ type Declarer interface

+ ExchangeDeclare func(name, kind string, durable, autoDelete, internal, noWait bool, args amqp.Table) error

+ QueueBind func(name, key, exchange string, noWait bool, args amqp.Table) error

+ QueueDeclare func(name string, durable, autoDelete, exclusive, noWait bool, args amqp.Table) (amqp.Queue, error)

+ type Exchange struct

+ AutoDelete bool

+ Durable bool

+ Kind string

+ Name string

+ type Publisher struct

+ func NewPublisher(exchange string, key string, opts ...PublisherOpt) *Publisher

+ func (p *Publisher) Cancel()

+ func (p *Publisher) Publish(pub amqp.Publishing) error

+ func (p *Publisher) Write(b []byte) (int, error)

+ type PublisherOpt func(*Publisher)

+ func PublishingTemplate(t amqp.Publishing) PublisherOpt

+ type Queue struct

+ AutoDelete bool

+ Durable bool

+ Exclusive bool

+ Name string