cony

package module

Go to main page

Versions in this module

v0

v0.3.3

Jul 26, 2019

Changes in this version

+ var ErrConfirmTimeOut = errors.New("confirm timed out")

+ var ErrConnected = errors.New("client already connected")

+ var ErrConnectionBlocked = errors.New("connection blocked")

+ var ErrConnectionClosedByClient = errors.New("connection closed by client")

+ var ErrConsumerServingStopped = errors.New("consumer serving stopped")

+ var ErrConsumerStopped = errors.New("consumer stopped")

+ var ErrDeliveriesChannelClosed = errors.New("consumer deliveries serving channel closed")

+ var ErrDisconnectTimeout = errors.New("disconnect timeout")

+ var ErrDisconnectWanted = errors.New("disconnect wanted")

+ var ErrFrequentDisconnect = errors.New("too frequent disconnects")

+ var ErrPublishTimeOut = errors.New("publish timed out")

+ var ErrPublisherServingStopped = errors.New("publisher serving stopped")

+ var ErrPublisherStopped = errors.New("publisher stopped")

+ var ErrPublishingNotConfirmed = errors.New("publishing NOT confirmed")

+ var ErrStopped = errors.New("client stopped")

type Binding

+ NoWait bool

type Client

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

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

+ func (c *Client) CloseCh() <-chan struct{}

+ func (c *Client) Closed() bool

+ func (c *Client) Connect() error

+ func (c *Client) Connected() bool

+ func (c *Client) Connection() (*amqp.Connection, error)

+ func (c *Client) Disconnect() error

+ func (c *Client) Redeclare() error

type ClientOpt

+ func Log(l Logger) ClientOpt

+ func URLs(addrs []string) ClientOpt

type Consumer

+ func (c *Consumer) AutoAck() bool

+ func (c *Consumer) Exclusive() bool

+ func (c *Consumer) NoLocal() bool

+ func (c *Consumer) Qos() int

+ func (c *Consumer) Serving() bool

+ func (c *Consumer) StopCh() <-chan struct{}

+ func (c *Consumer) Stopped() bool

+ func (c *Consumer) Tag() string

type ConsumerOpt

+ func ConsumerLog(l Logger) ConsumerOpt

+ type ErrorsBatch struct

+ func NewErrorBatch() *ErrorsBatch

+ func (eb *ErrorsBatch) Add(err error)

+ func (eb *ErrorsBatch) CheckEPS(k float64) bool

+ func (eb *ErrorsBatch) Errors() []error

+ func (eb *ErrorsBatch) First() *time.Time

+ func (eb *ErrorsBatch) GetEPS() float64

+ func (eb *ErrorsBatch) Last() *time.Time

+ func (eb *ErrorsBatch) Len() int

+ func (eb *ErrorsBatch) Reset()

+ func (eb *ErrorsBatch) Snapshot() *ErrorsBatchSnapshot

+ func (eb *ErrorsBatch) String() string

+ type ErrorsBatchSnapshot struct

+ Errors []error

+ ErrorsLen int

+ First *time.Time

+ Last *time.Time

+ LastReset *time.Time

type Exchange

+ Internal bool

+ NoWait bool

+ type Logger interface

+ Crit func(msg string, ctx ...interface{})

+ Debug func(msg string, ctx ...interface{})

+ Error func(msg string, ctx ...interface{})

+ Info func(msg string, ctx ...interface{})

+ Trace func(msg string, ctx ...interface{})

+ Warn func(msg string, ctx ...interface{})

type Publisher

+ func (p *Publisher) ConfirmTimeout() time.Duration

+ func (p *Publisher) Errors() <-chan error

+ func (p *Publisher) Exchange() string

+ func (p *Publisher) PublishWithParams(pub *amqp.Publishing, exchange string, key string, timeout time.Duration) error

+ func (p *Publisher) RoutingKey() string

+ func (p *Publisher) Serving() bool

+ func (p *Publisher) StopCh() <-chan struct{}

+ func (p *Publisher) Stopped() bool

type PublisherOpt

+ func PublisherConfirmTimeout(t time.Duration) PublisherOpt

+ func PublisherLog(l Logger) PublisherOpt

type Queue

+ NoWait bool

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

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