rabbitmq

package module

Go to main page

Versions in this module

v0

v0.2.10

Jun 14, 2023

Changes in this version

+ func WithPublisherOptionsConfirm(options *PublisherOptions)

type PublisherOptions

+ ConfirmMode bool

v0.2.9

Apr 27, 2023

v0.2.8

Apr 27, 2023

Changes in this version

type Conn

+ func (conn *Conn) RegisterReconnectHook(hook func())

v0.2.7

Apr 26, 2023

v0.2.6

Apr 26, 2023

v0.2.5

Apr 25, 2023

v0.2.4

Apr 25, 2023

Changes in this version

type Declarator

+ func (d *Declarator) BindExchanges(bindings []ExchangeBinding) error

+ func (d *Declarator) DeclareExchange(options ExchangeOptions) error

+ func (d *Declarator) DeclareQueue(options QueueOptions) error

v0.2.3

Apr 24, 2023

v0.2.2

Apr 24, 2023

Changes in this version

type Declarator

+ func (d *Declarator) Close()

+ type ExchangeBinding struct

+ Args Table

+ From string

+ NoWait bool

+ RoutingKey string

+ To string

v0.2.1

Apr 24, 2023

v0.2.0

Apr 24, 2023

Changes in this version

+ type Declarator struct

+ func NewDeclarator(conn *Conn) (*Declarator, error)

+ func (d *Declarator) Declare(options ConsumerOptions) error

v0.1.0

Apr 24, 2023

Changes in this version

+ const Persistent

+ const Transient

+ func WithConnectionOptionsConfig(cfg Config) func(options *ConnectionOptions)

+ func WithConnectionOptionsLogger(log Logger) func(options *ConnectionOptions)

+ func WithConnectionOptionsLogging(options *ConnectionOptions)

+ func WithConnectionOptionsReconnectInterval(interval time.Duration) func(options *ConnectionOptions)

+ func WithConsumerOptionsBinding(binding Binding) func(*ConsumerOptions)

+ func WithConsumerOptionsConcurrency(concurrency int) func(*ConsumerOptions)

+ func WithConsumerOptionsConsumerAutoAck(autoAck bool) func(*ConsumerOptions)

+ func WithConsumerOptionsConsumerExclusive(options *ConsumerOptions)

+ func WithConsumerOptionsConsumerName(consumerName string) func(*ConsumerOptions)

+ func WithConsumerOptionsConsumerNoWait(options *ConsumerOptions)

+ func WithConsumerOptionsExchangeArgs(args Table) func(*ConsumerOptions)

+ func WithConsumerOptionsExchangeAutoDelete(options *ConsumerOptions)

+ func WithConsumerOptionsExchangeDeclare(options *ConsumerOptions)

+ func WithConsumerOptionsExchangeDurable(options *ConsumerOptions)

+ func WithConsumerOptionsExchangeInternal(options *ConsumerOptions)

+ func WithConsumerOptionsExchangeKind(kind string) func(*ConsumerOptions)

+ func WithConsumerOptionsExchangeName(name string) func(*ConsumerOptions)

+ func WithConsumerOptionsExchangeNoWait(options *ConsumerOptions)

+ func WithConsumerOptionsExchangePassive(options *ConsumerOptions)

+ func WithConsumerOptionsLogger(log logger.Logger) func(options *ConsumerOptions)

+ func WithConsumerOptionsLogging(options *ConsumerOptions)

+ func WithConsumerOptionsQOSGlobal(options *ConsumerOptions)

+ func WithConsumerOptionsQOSPrefetch(prefetchCount int) func(*ConsumerOptions)

+ func WithConsumerOptionsQueueArgs(args Table) func(*ConsumerOptions)

+ func WithConsumerOptionsQueueAutoDelete(options *ConsumerOptions)

+ func WithConsumerOptionsQueueDurable(options *ConsumerOptions)

+ func WithConsumerOptionsQueueExclusive(options *ConsumerOptions)

+ func WithConsumerOptionsQueueNoDeclare(options *ConsumerOptions)

+ func WithConsumerOptionsQueueNoWait(options *ConsumerOptions)

+ func WithConsumerOptionsQueuePassive(options *ConsumerOptions)

+ func WithConsumerOptionsQueueQuorum(options *ConsumerOptions)

+ func WithConsumerOptionsRoutingKey(routingKey string) func(*ConsumerOptions)

+ func WithPublishOptionsAppID(appID string) func(*PublishOptions)

+ func WithPublishOptionsContentEncoding(contentEncoding string) func(*PublishOptions)

+ func WithPublishOptionsContentType(contentType string) func(*PublishOptions)

+ func WithPublishOptionsCorrelationID(correlationID string) func(*PublishOptions)

+ func WithPublishOptionsExchange(exchange string) func(*PublishOptions)

+ func WithPublishOptionsExpiration(expiration string) func(options *PublishOptions)

+ func WithPublishOptionsHeaders(headers Table) func(*PublishOptions)

+ func WithPublishOptionsImmediate(options *PublishOptions)

+ func WithPublishOptionsMandatory(options *PublishOptions)

+ func WithPublishOptionsMessageID(messageID string) func(*PublishOptions)

+ func WithPublishOptionsPersistentDelivery(options *PublishOptions)

+ func WithPublishOptionsPriority(priority uint8) func(*PublishOptions)

+ func WithPublishOptionsReplyTo(replyTo string) func(*PublishOptions)

+ func WithPublishOptionsTimestamp(timestamp time.Time) func(*PublishOptions)

+ func WithPublishOptionsType(messageType string) func(*PublishOptions)

+ func WithPublishOptionsUserID(userID string) func(*PublishOptions)

+ func WithPublisherOptionsExchangeArgs(args Table) func(*PublisherOptions)

+ func WithPublisherOptionsExchangeAutoDelete(options *PublisherOptions)

+ func WithPublisherOptionsExchangeDeclare(options *PublisherOptions)

+ func WithPublisherOptionsExchangeDurable(options *PublisherOptions)

+ func WithPublisherOptionsExchangeInternal(options *PublisherOptions)

+ func WithPublisherOptionsExchangeKind(kind string) func(*PublisherOptions)

+ func WithPublisherOptionsExchangeName(name string) func(*PublisherOptions)

+ func WithPublisherOptionsExchangeNoWait(options *PublisherOptions)

+ func WithPublisherOptionsExchangePassive(options *PublisherOptions)

+ func WithPublisherOptionsLogger(log Logger) func(options *PublisherOptions)

+ func WithPublisherOptionsLogging(options *PublisherOptions)

+ type Action int

+ const Ack

+ const Manual

+ const NackDiscard

+ const NackRequeue

+ type Binding struct

+ RoutingKey string

+ type BindingOptions struct

+ Args Table

+ Declare bool

+ NoWait bool

+ type Config amqp.Config

+ type Confirmation struct

+ ReconnectionCount int

+ type Conn struct

+ func NewConn(url string, optionFuncs ...func(*ConnectionOptions)) (*Conn, error)

+ func (conn *Conn) Close() error

+ type ConnectionOptions struct

+ Config Config

+ Logger Logger

+ ReconnectInterval time.Duration

+ type Consumer struct

+ func NewConsumer(conn *Conn, handler Handler, queue string, ...) (*Consumer, error)

+ func (consumer *Consumer) Close()

+ type ConsumerOptions struct

+ Bindings []Binding

+ Concurrency int

+ ExchangeOptions ExchangeOptions

+ Logger logger.Logger

+ QOSGlobal bool

+ QOSPrefetch int

+ QueueOptions QueueOptions

+ RabbitConsumerOptions RabbitConsumerOptions

+ type Delivery struct

+ type ExchangeOptions struct

+ Args Table

+ AutoDelete bool

+ Declare bool

+ Durable bool

+ Internal bool

+ Kind string

+ Name string

+ NoWait bool

+ Passive bool

+ type Handler func(d Delivery) (action Action)

+ type Logger logger.Logger

+ type PublishOptions struct

+ AppID string

+ ContentEncoding string

+ ContentType string

+ CorrelationID string

+ DeliveryMode uint8

+ Exchange string

+ Expiration string

+ Headers Table

+ Immediate bool

+ Mandatory bool

+ MessageID string

+ Priority uint8

+ ReplyTo string

+ Timestamp time.Time

+ Type string

+ UserID string

+ type Publisher struct

+ func NewPublisher(conn *Conn, optionFuncs ...func(*PublisherOptions)) (*Publisher, error)

+ func (publisher *Publisher) Close()

+ func (publisher *Publisher) NotifyPublish(handler func(p Confirmation))

+ func (publisher *Publisher) NotifyReturn(handler func(r Return))

+ func (publisher *Publisher) Publish(data []byte, routingKeys []string, optionFuncs ...func(*PublishOptions)) error

+ func (publisher *Publisher) PublishWithContext(ctx context.Context, data []byte, routingKeys []string, ...) error

+ func (publisher *Publisher) PublishWithDeferredConfirmWithContext(ctx context.Context, data []byte, routingKeys []string, ...) (PublisherConfirmation, error)

+ type PublisherConfirmation []*amqp.DeferredConfirmation

+ type PublisherOptions struct

+ ExchangeOptions ExchangeOptions

+ Logger Logger

+ type QueueOptions struct

+ Args Table

+ AutoDelete bool

+ Declare bool

+ Durable bool

+ Exclusive bool

+ Name string

+ NoWait bool

+ Passive bool

+ type RabbitConsumerOptions struct

+ Args Table

+ AutoAck bool

+ Exclusive bool

+ Name string

+ NoLocal bool

+ NoWait bool

+ type Return struct

+ type Table map[string]interface

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