rabbit

package module

Go to main page

Versions in this module

v0

v0.3.6

Feb 5, 2024

v0.3.5

Jun 23, 2023

v0.3.4

Jun 23, 2023

v0.3.3

Jun 23, 2023

v0.3.2

Jun 23, 2023

v0.3.1

Mar 1, 2023

v0.3.0

Mar 1, 2023

Changes in this version

type Channel

+ func (c *Channel) PublishWithDeferredConfirm(exchange, key string, mandatory, immediate bool, msg amqp091.Publishing) (*amqp091.DeferredConfirmation, error)

+ func (c *Channel) PublishWithDeferredConfirmContext(ctx context.Context, exchange, key string, mandatory, immediate bool, ...) (*amqp091.DeferredConfirmation, error)

type ChannelPool

+ func (cp *ChannelPool) Acquire() (*Channel, error)

+ func (cp *ChannelPool) PublishWithDeferredConfirm(exchange, key string, mandatory, immediate bool, msg amqp091.Publishing) (*amqp091.DeferredConfirmation, error)

+ func (cp *ChannelPool) PublishWithDeferredConfirmContext(ctx context.Context, exchange, key string, mandatory, immediate bool, ...) (*amqp091.DeferredConfirmation, error)

+ func (cp *ChannelPool) Put(conn *Channel) error

v0.2.4

Oct 6, 2022

Changes in this version

type Channel

+ func (c *Channel) Ping() error

type ChannelPool

+ func (cp *ChannelPool) Ack(tag uint64, multiple bool) error

+ func (cp *ChannelPool) Cancel(consumer string, noWait bool) error

+ func (cp *ChannelPool) Confirm(noWait bool) error

+ func (cp *ChannelPool) Consume(queue, consumer string, autoAck, exclusive, noLocal, noWait bool, ...) (<-chan amqp.Delivery, error)

+ func (cp *ChannelPool) ExchangeBind(destination, key, source string, noWait bool, args amqp.Table) error

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

+ func (cp *ChannelPool) ExchangeDeclarePassive(name, kind string, durable, autoDelete, internal, noWait bool, args amqp.Table) error

+ func (cp *ChannelPool) ExchangeDelete(name string, ifUnused, noWait bool) error

+ func (cp *ChannelPool) ExchangeUnbind(destination, key, source string, noWait bool, args amqp.Table) error

+ func (cp *ChannelPool) Flow(active bool) error

+ func (cp *ChannelPool) Get(queue string, autoAck bool) (msg amqp.Delivery, ok bool, err error)

+ func (cp *ChannelPool) Nack(tag uint64, multiple bool, requeue bool) error

+ func (cp *ChannelPool) NotifyCancel(ch chan string) (chan string, error)

+ func (cp *ChannelPool) NotifyClose(ch chan *amqp.Error) (chan *amqp.Error, error)

+ func (cp *ChannelPool) NotifyConfirm(ack, nack chan uint64) (chan uint64, chan uint64, error)

+ func (cp *ChannelPool) NotifyFlow(ch chan bool) (chan bool, error)

+ func (cp *ChannelPool) NotifyPublish(confirm chan amqp.Confirmation) (chan amqp.Confirmation, error)

+ func (cp *ChannelPool) NotifyReturn(ch chan amqp.Return) (chan amqp.Return, error)

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

+ func (cp *ChannelPool) Qos(prefetchCount, prefetchSize int, global bool) error

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

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

+ func (cp *ChannelPool) QueueDeclarePassive(name string, durable, autoDelete, exclusive, noWait bool, args amqp.Table) (amqp.Queue, error)

+ func (cp *ChannelPool) QueueDelete(name string, ifUnused, ifEmpty, noWait bool) (int, error)

+ func (cp *ChannelPool) QueueInspect(name string) (amqp.Queue, error)

+ func (cp *ChannelPool) QueuePurge(name string, noWait bool) (int, error)

+ func (cp *ChannelPool) QueueUnbind(name, key, exchange string, args amqp.Table) error

+ func (cp *ChannelPool) Recover(requeue bool) error

+ func (cp *ChannelPool) Reject(tag uint64, requeue bool) error

+ func (cp *ChannelPool) Tx() error

+ func (cp *ChannelPool) TxCommit() error

+ func (cp *ChannelPool) TxRollback() error

type ChannelPoolConfig

+ IdleTimeout time.Duration

type Connection

+ func (c *Connection) Ping() error

type ConnectionPoolConfig

+ IdleTimeout time.Duration

v0.2.3

Sep 12, 2022

v0.2.2

Sep 9, 2022

v0.2.1

Sep 7, 2022

v0.2.0

Sep 7, 2022

Changes in this version

+ var ErrChannelClosed = errors.New("channel already closed")

+ var ErrChannelIsNil = errors.New("channel is nil")

+ var ErrConnectionClosed = errors.New("connection already closed")

+ var ErrConnectionIsNil = errors.New("connection is nil")

+ var ErrInvalidCapacity = errors.New("invalid pool capacity")

type Channel

+ func (c *Channel) MarkUnusable()

+ type ChannelPool struct

+ func (cp *ChannelPool) AckContext(ctx context.Context, tag uint64, multiple bool) error

+ func (cp *ChannelPool) CancelContext(ctx context.Context, consumer string, noWait bool) error

+ func (cp *ChannelPool) Close() (err error)

+ func (cp *ChannelPool) ConfirmContext(ctx context.Context, noWait bool) error

+ func (cp *ChannelPool) ConsumeContext(ctx context.Context, queue, consumer string, ...) (<-chan amqp.Delivery, error)

+ func (cp *ChannelPool) ExchangeBindContext(ctx context.Context, destination, key, source string, noWait bool, ...) error

+ func (cp *ChannelPool) ExchangeDeclareContext(ctx context.Context, name, kind string, ...) error

+ func (cp *ChannelPool) ExchangeDeclarePassiveContext(ctx context.Context, name, kind string, ...) error

+ func (cp *ChannelPool) ExchangeDeleteContext(ctx context.Context, name string, ifUnused, noWait bool) error

+ func (cp *ChannelPool) ExchangeUnbindContext(ctx context.Context, destination, key, source string, noWait bool, ...) error

+ func (cp *ChannelPool) FlowContext(ctx context.Context, active bool) error

+ func (cp *ChannelPool) GetChannel(ctx context.Context) (*Channel, error)

+ func (cp *ChannelPool) GetContext(ctx context.Context, queue string, autoAck bool) (msg amqp.Delivery, ok bool, err error)

+ func (cp *ChannelPool) NackContext(ctx context.Context, tag uint64, multiple bool, requeue bool) error

+ func (cp *ChannelPool) NotifyCancelContext(ctx context.Context, ch chan string) (chan string, error)

+ func (cp *ChannelPool) NotifyCloseContext(ctx context.Context, ch chan *amqp.Error) (chan *amqp.Error, error)

+ func (cp *ChannelPool) NotifyConfirmContext(ctx context.Context, ack, nack chan uint64) (chan uint64, chan uint64, error)

+ func (cp *ChannelPool) NotifyFlowContext(ctx context.Context, ch chan bool) (chan bool, error)

+ func (cp *ChannelPool) NotifyPublishContext(ctx context.Context, confirm chan amqp.Confirmation) (chan amqp.Confirmation, error)

+ func (cp *ChannelPool) NotifyReturnContext(ctx context.Context, ch chan amqp.Return) (chan amqp.Return, error)

+ func (cp *ChannelPool) PublishContext(ctx context.Context, exchange, key string, mandatory, immediate bool, ...) error

+ func (cp *ChannelPool) QosContext(ctx context.Context, prefetchCount, prefetchSize int, global bool) error

+ func (cp *ChannelPool) QueueBindContext(ctx context.Context, name, key, exchange string, noWait bool, args amqp.Table) error

+ func (cp *ChannelPool) QueueDeclareContext(ctx context.Context, name string, durable, autoDelete, exclusive, noWait bool, ...) (amqp.Queue, error)

+ func (cp *ChannelPool) QueueDeclarePassiveContext(ctx context.Context, name string, durable, autoDelete, exclusive, noWait bool, ...) (amqp.Queue, error)

+ func (cp *ChannelPool) QueueDeleteContext(ctx context.Context, name string, ifUnused, ifEmpty, noWait bool) (int, error)

+ func (cp *ChannelPool) QueueInspectContext(ctx context.Context, name string) (amqp.Queue, error)

+ func (cp *ChannelPool) QueuePurgeContext(ctx context.Context, name string, noWait bool) (int, error)

+ func (cp *ChannelPool) QueueUnbindContext(ctx context.Context, name, key, exchange string, args amqp.Table) error

+ func (cp *ChannelPool) RecoverContext(ctx context.Context, requeue bool) error

+ func (cp *ChannelPool) RejectContext(ctx context.Context, tag uint64, requeue bool) error

+ func (cp *ChannelPool) TxCommitContext(ctx context.Context) error

+ func (cp *ChannelPool) TxContext(ctx context.Context) error

+ func (cp *ChannelPool) TxRollbackContext(ctx context.Context) error

+ type ChannelPoolConfig struct

+ MaxChannels int

+ MinChannels int

type Connection

+ func (c *Connection) ChannelPool(cfg *ChannelPoolConfig) (*ChannelPool, error)

+ func (c *Connection) MarkUnusable()

+ type ConnectionPool struct

+ func NewConnectionPool(ctx context.Context, connCfg *Config, poolCfg *ConnectionPoolConfig) (*ConnectionPool, error)

+ func (cp *ConnectionPool) Channel(ctx context.Context) (*Channel, error)

+ func (cp *ConnectionPool) ChannelPool(ctx context.Context, cfg *ChannelPoolConfig) (*ChannelPool, error)

+ func (cp *ConnectionPool) Close()

+ func (cp *ConnectionPool) GetConnection(ctx context.Context) (*Connection, error)

+ type ConnectionPoolConfig struct

+ MaxConns int

+ MinConns int

v0.1.6

Jul 21, 2022

v0.1.5

Jul 19, 2022

Changes in this version

type Channel

+ func (c *Channel) AckContext(ctx context.Context, tag uint64, multiple bool) error

+ func (c *Channel) CancelContext(ctx context.Context, consumer string, noWait bool) error

+ func (c *Channel) ConfirmContext(ctx context.Context, noWait bool) error

+ func (c *Channel) ConsumeContext(ctx context.Context, queue, consumer string, ...) (<-chan amqp.Delivery, error)

+ func (c *Channel) ExchangeBindContext(ctx context.Context, destination, key, source string, noWait bool, ...) error

+ func (c *Channel) ExchangeDeclareContext(ctx context.Context, name, kind string, ...) error

+ func (c *Channel) ExchangeDeclarePassiveContext(ctx context.Context, name, kind string, ...) error

+ func (c *Channel) ExchangeDeleteContext(ctx context.Context, name string, ifUnused, noWait bool) error

+ func (c *Channel) ExchangeUnbindContext(ctx context.Context, destination, key, source string, noWait bool, ...) error

+ func (c *Channel) FlowContext(ctx context.Context, active bool) error

+ func (c *Channel) GetContext(ctx context.Context, queue string, autoAck bool) (msg amqp.Delivery, ok bool, err error)

+ func (c *Channel) NackContext(ctx context.Context, tag uint64, multiple bool, requeue bool) error

+ func (c *Channel) NotifyCancelContext(ctx context.Context, ch chan string) (chan string, error)

+ func (c *Channel) NotifyCloseContext(ctx context.Context, ch chan *amqp.Error) (chan *amqp.Error, error)

+ func (c *Channel) NotifyConfirmContext(ctx context.Context, ack, nack chan uint64) (chan uint64, chan uint64, error)

+ func (c *Channel) NotifyFlowContext(ctx context.Context, ch chan bool) (chan bool, error)

+ func (c *Channel) NotifyPublishContext(ctx context.Context, confirm chan amqp.Confirmation) (chan amqp.Confirmation, error)

+ func (c *Channel) NotifyReturnContext(ctx context.Context, ch chan amqp.Return) (chan amqp.Return, error)

+ func (c *Channel) PublishContext(ctx context.Context, exchange, key string, mandatory, immediate bool, ...) error

+ func (c *Channel) QosContext(ctx context.Context, prefetchCount, prefetchSize int, global bool) error

+ func (c *Channel) QueueBindContext(ctx context.Context, name, key, exchange string, noWait bool, args amqp.Table) error

+ func (c *Channel) QueueDeclareContext(ctx context.Context, name string, durable, autoDelete, exclusive, noWait bool, ...) (amqp.Queue, error)

+ func (c *Channel) QueueDeclarePassiveContext(ctx context.Context, name string, durable, autoDelete, exclusive, noWait bool, ...) (amqp.Queue, error)

+ func (c *Channel) QueueDeleteContext(ctx context.Context, name string, ifUnused, ifEmpty, noWait bool) (int, error)

+ func (c *Channel) QueueInspectContext(ctx context.Context, name string) (amqp.Queue, error)

+ func (c *Channel) QueuePurgeContext(ctx context.Context, name string, noWait bool) (int, error)

+ func (c *Channel) QueueUnbindContext(ctx context.Context, name, key, exchange string, args amqp.Table) error

+ func (c *Channel) RecoverContext(ctx context.Context, requeue bool) error

+ func (c *Channel) RejectContext(ctx context.Context, tag uint64, requeue bool) error

+ func (c *Channel) TxCommitContext(ctx context.Context) error

+ func (c *Channel) TxContext(ctx context.Context) error

+ func (c *Channel) TxRollbackContext(ctx context.Context) error

v0.1.4

Jun 23, 2022

v0.1.3

Jun 19, 2022

v0.1.2

May 14, 2022

v0.1.1

May 14, 2022

v0.1.0

May 14, 2022

Changes in this version

+ type Channel struct

+ func (c *Channel) Ack(tag uint64, multiple bool) error

+ func (c *Channel) Cancel(consumer string, noWait bool) error

+ func (c *Channel) Channel() *amqp.Channel

+ func (c *Channel) Close() error

+ func (c *Channel) Confirm(noWait bool) error

+ func (c *Channel) Consume(queue, consumer string, autoAck, exclusive, noLocal, noWait bool, ...) (<-chan amqp.Delivery, error)

+ func (c *Channel) ExchangeBind(destination, key, source string, noWait bool, args amqp.Table) error

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

+ func (c *Channel) ExchangeDeclarePassive(name, kind string, durable, autoDelete, internal, noWait bool, args amqp.Table) error

+ func (c *Channel) ExchangeDelete(name string, ifUnused, noWait bool) error

+ func (c *Channel) ExchangeUnbind(destination, key, source string, noWait bool, args amqp.Table) error

+ func (c *Channel) Flow(active bool) error

+ func (c *Channel) Get(queue string, autoAck bool) (msg amqp.Delivery, ok bool, err error)

+ func (c *Channel) Monitor()

+ func (c *Channel) Nack(tag uint64, multiple bool, requeue bool) error

+ func (c *Channel) NotifyCancel(ch chan string) chan string

+ func (c *Channel) NotifyClose(ch chan *amqp.Error) chan *amqp.Error

+ func (c *Channel) NotifyConfirm(ack, nack chan uint64) (chan uint64, chan uint64)

+ func (c *Channel) NotifyFlow(ch chan bool) chan bool

+ func (c *Channel) NotifyPublish(confirm chan amqp.Confirmation) chan amqp.Confirmation

+ func (c *Channel) NotifyReturn(ch chan amqp.Return) chan amqp.Return

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

+ func (c *Channel) Qos(prefetchCount, prefetchSize int, global bool) error

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

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

+ func (c *Channel) QueueDeclarePassive(name string, durable, autoDelete, exclusive, noWait bool, args amqp.Table) (amqp.Queue, error)

+ func (c *Channel) QueueDelete(name string, ifUnused, ifEmpty, noWait bool) (int, error)

+ func (c *Channel) QueueInspect(name string) (amqp.Queue, error)

+ func (c *Channel) QueuePurge(name string, noWait bool) (int, error)

+ func (c *Channel) QueueUnbind(name, key, exchange string, args amqp.Table) error

+ func (c *Channel) Recover(requeue bool) error

+ func (c *Channel) Reject(tag uint64, requeue bool) error

+ func (c *Channel) Tx() error

+ func (c *Channel) TxCommit() error

+ func (c *Channel) TxRollback() error

+ type Config struct

+ AmqpCfg amqp.Config

+ Heartbeat time.Duration

+ Host string

+ MaxRetries int

+ Password string

+ Port int

+ User string

+ type Connection struct

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

+ func (c *Connection) Channel() (*Channel, error)

+ func (c *Connection) Close() error

+ func (c *Connection) Connection() *amqp.Connection

+ func (c *Connection) Monitor()

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