rabbit

Dec 15, 2021

Changes in this version

type Options

+ QueueArgs map[string]interface{}

Feb 17, 2021

Changes in this version

+ type Logger interface

+ Debug func(args ...interface{})

+ Debugf func(format string, args ...interface{})

+ Error func(args ...interface{})

+ Errorf func(format string, args ...interface{})

+ Info func(args ...interface{})

+ Infof func(format string, args ...interface{})

+ Warn func(args ...interface{})

+ Warnf func(format string, args ...interface{})

+ type NoOpLogger struct

+ func (l *NoOpLogger) Debug(args ...interface{})

+ func (l *NoOpLogger) Debugf(format string, args ...interface{})

+ func (l *NoOpLogger) Error(args ...interface{})

+ func (l *NoOpLogger) Errorf(format string, args ...interface{})

+ func (l *NoOpLogger) Info(args ...interface{})

+ func (l *NoOpLogger) Infof(format string, args ...interface{})

+ func (l *NoOpLogger) Warn(args ...interface{})

+ func (l *NoOpLogger) Warnf(format string, args ...interface{})

type Options

+ Log Logger

Feb 3, 2021

Changes in this version

+ var ErrShutdown = errors.New("connection has been shutdown")

Feb 3, 2021

Changes in this version

+ type Binding struct

+ BindingKeys []string

+ ExchangeAutoDelete bool

+ ExchangeDeclare bool

+ ExchangeDurable bool

+ ExchangeName string

+ ExchangeType string

type Options

+ Bindings []Binding

Jan 31, 2021

Changes in this version

type Options

+ URLs []string

Jan 20, 2021

Changes in this version

type Options

+ BindingKeys []string

Dec 3, 2020

Changes in this version

+ var ShutdownError = errors.New("connection has been shutdown")

type Options

+ SkipVerifyTLS bool

+ UseTLS bool

Oct 18, 2020

Changes in this version

+ var DefaultAppID = "p-rabbit-" + uuid.NewV4().String()[0:8]

+ var DefaultConsumerTag = "c-rabbit-" + uuid.NewV4().String()[0:8]

type Options

+ AppID string

+ ConsumerTag string

Oct 11, 2020

Changes in this version

type IRabbit

+ Close func() error

type Rabbit

+ func (r *Rabbit) Close() error

Oct 6, 2020

Changes in this version

+ type Mode int

+ const Both

+ const Consumer

+ const Producer

type Options

+ Mode Mode

Oct 5, 2020

Changes in this version

type Options

+ AutoAck bool

Oct 4, 2020

Changes in this version

+ const DefaultRetryReconnectSec

+ func ValidateOptions(opts *Options) error

+ type ConsumeError struct

+ Error error

+ Message *amqp.Delivery

+ type IRabbit interface

+ Consume func(ctx context.Context, errChan chan *ConsumeError, ...)

+ ConsumeOnce func(ctx context.Context, runFunc func(msg amqp.Delivery) error) error

+ Publish func(ctx context.Context, routingKey string, payload []byte) error

+ Stop func() error

+ type Options struct

+ ExchangeAutoDelete bool

+ ExchangeDeclare bool

+ ExchangeDurable bool

+ ExchangeName string

+ ExchangeType string

+ QosPrefetchCount int

+ QosPrefetchSize int

+ QueueAutoDelete bool

+ QueueDeclare bool

+ QueueDurable bool

+ QueueExclusive bool

+ QueueName string

+ RetryReconnectSec int

+ RoutingKey string

+ URL string

+ type Rabbit struct

+ Conn *amqp.Connection

+ ConsumeLooper director.Looper

+ ConsumerDeliveryChannel <-chan amqp.Delivery

+ ConsumerRWMutex *sync.RWMutex

+ NotifyCloseChan chan *amqp.Error

+ Options *Options

+ ProducerRWMutex *sync.RWMutex

+ ProducerServerChannel *amqp.Channel

+ func New(opts *Options) (*Rabbit, error)

+ func (r *Rabbit) Consume(ctx context.Context, errChan chan *ConsumeError, ...)

+ func (r *Rabbit) ConsumeOnce(ctx context.Context, runFunc func(msg amqp.Delivery) error) error

+ func (r *Rabbit) Publish(ctx context.Context, routingKey string, body []byte) error

+ func (r *Rabbit) Stop() error