rabbitmq

Jun 21, 2024

Changes in this version

+ func WithConsumerOptionsForceShutdown(options *ConsumerOptions)

type Conn

+ func NewClusterConn(resolver Resolver, opts ...func(*ConnectionOptions)) (*Conn, error)

type Consumer

+ func (consumer *Consumer) CloseWithContext(ctx context.Context)

type ConsumerOptions

+ CloseGracefully bool

+ type Resolver = connectionmanager.Resolver

+ type StaticResolver struct

+ func NewStaticResolver(urls []string, shuffle bool) *StaticResolver

+ func (r *StaticResolver) Resolve() ([]string, error)

Mar 4, 2024

Changes in this version

+ func WithConsumerOptionsExchangeOptions(exchangeOptions ExchangeOptions) func(*ConsumerOptions)

type Consumer

+ func (consumer *Consumer) Run(handler Handler) error

type ExchangeOptions

+ Bindings []Binding

Jul 5, 2023

Changes in this version

+ func WithPublisherOptionsConfirm(options *PublisherOptions)

type PublisherOptions

+ ConfirmMode bool

Mar 20, 2023

Changes in this version

type Action

+ const Manual

type Publisher

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

+ type PublisherConfirmation []*amqp.DeferredConfirmation

Feb 6, 2023

Changes in this version

type Publisher

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

Dec 31, 2022

Changes in this version

+ func WithConsumerOptionsQueueQuorum(options *ConsumerOptions)

Dec 2, 2022

Changes in this version

+ 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 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 WithConsumerOptionsRoutingKey(routingKey string) func(*ConsumerOptions)

+ 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)

+ type Binding struct

+ RoutingKey string

type BindingOptions

+ Declare bool

+ 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 ConsumerOptions

+ Bindings []Binding

+ Concurrency int

+ ExchangeOptions ExchangeOptions

+ QOSGlobal bool

+ QOSPrefetch int

+ QueueOptions QueueOptions

+ RabbitConsumerOptions RabbitConsumerOptions

+ type ExchangeOptions struct

+ Args Table

+ AutoDelete bool

+ Declare bool

+ Durable bool

+ Internal bool

+ Kind string

+ Name string

+ NoWait bool

+ Passive bool

type PublisherOptions

+ ExchangeOptions ExchangeOptions

type QueueOptions

+ Declare bool

+ Name string

+ Passive bool

+ type RabbitConsumerOptions struct

+ Args Table

+ AutoAck bool

+ Exclusive bool

+ Name string

+ NoLocal bool

+ NoWait bool

May 21, 2022

Changes in this version

type Logger

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

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

+ Fatalf func(string, ...interface{})

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

+ Tracef func(string, ...interface{})

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

May 20, 2022

Changes in this version

type Logger

+ DebugF func(string, ...interface{})

+ ErrorF func(string, ...interface{})

+ FatalF func(string, ...interface{})

+ InfoF func(string, ...interface{})

+ TraceF func(string, ...interface{})

+ WarnF func(string, ...interface{})

Apr 24, 2022

Changes in this version

type Confirmation

+ ReconnectionCount int

Apr 5, 2022

Changes in this version

+ type Config amqp.Config

type Consumer

+ func (consumer Consumer) Close() error

type Publisher

+ func (publisher Publisher) Close() error

Mar 20, 2022

Changes in this version

+ func WithConsumerOptionsReconnectInterval(reconnectInterval time.Duration) func(options *ConsumerOptions)

+ func WithPublisherOptionsReconnectInterval(reconnectInterval time.Duration) func(options *ConsumerOptions)

type ConsumerOptions

+ ReconnectInterval time.Duration

type PublisherOptions

+ ReconnectInterval time.Duration

Dec 7, 2021

Changes in this version

+ func WithConsumeOptionsBindingExchangeSkipDeclare(options *ConsumeOptions)

+ func WithConsumeOptionsQueueArgs(args Table) func(*ConsumeOptions)

+ func WithConsumeOptionsQueueNoDeclare(options *ConsumeOptions)

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

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

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

+ func WithPublishOptionsMessageID(messageID string) func(*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)

+ type Action int

+ const Ack

+ const NackDiscard

+ const NackRequeue

type BindingExchangeOptions

+ Declare bool

+ type Confirmation struct

type ConsumeOptions

+ QueueDeclare bool

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

type PublishOptions

+ AppID string

+ ContentEncoding string

+ CorrelationID string

+ MessageID string

+ Priority uint8

+ ReplyTo string

+ Timestamp time.Time

+ Type string

+ UserID string

type Publisher

+ func (publisher *Publisher) NotifyPublish() <-chan Confirmation

+ func (publisher *Publisher) NotifyReturn() <-chan Return

Jul 13, 2021

Changes in this version

+ func WithConsumeOptionsConsumerAutoAck(autoAck bool) func(*ConsumeOptions)

type Consumer

+ func (consumer Consumer) Disconnect()

type Publisher

+ func (publisher Publisher) StopPublishing()

Jun 6, 2021

Changes in this version

+ func WithConsumeOptionsBindingExchangeArgs(args Table) func(*ConsumeOptions)

+ func WithConsumeOptionsBindingExchangeAutoDelete(options *ConsumeOptions)

+ func WithConsumeOptionsBindingExchangeDurable(options *ConsumeOptions)

+ func WithConsumeOptionsBindingExchangeInternal(options *ConsumeOptions)

+ func WithConsumeOptionsBindingExchangeKind(kind string) func(*ConsumeOptions)

+ func WithConsumeOptionsBindingExchangeName(name string) func(*ConsumeOptions)

+ func WithConsumeOptionsBindingExchangeNoWait(options *ConsumeOptions)

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

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

+ type BindingExchangeOptions struct

+ AutoDelete bool

+ Durable bool

+ ExchangeArgs Table

+ Internal bool

+ Kind string

+ Name string

+ NoWait bool

type Consumer

+ func (consumer Consumer) StopConsuming()

type PublishOptions

+ Expiration string

+ Headers Table

Apr 7, 2021

Changes in this version

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

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

type ConsumerOptions

+ Logger Logger

+ type Logger interface

+ Printf func(string, ...interface{})

type PublisherOptions

+ Logger Logger

Mar 9, 2021

Changes in this version

+ func WithConsumeOptionsBindingExchange(exchange string) func(*ConsumeOptions)

+ func WithConsumeOptionsBindingNoWait(options *ConsumeOptions)

+ func WithConsumeOptionsConcurrency(concurrency int) func(*ConsumeOptions)

+ func WithConsumeOptionsConsumerExclusive(options *ConsumeOptions)

+ func WithConsumeOptionsConsumerName(consumerName string) func(*ConsumeOptions)

+ func WithConsumeOptionsConsumerNoWait(options *ConsumeOptions)

+ func WithConsumeOptionsQOSGlobal(options *ConsumeOptions)

+ func WithConsumeOptionsQOSPrefetch(prefetchCount int) func(*ConsumeOptions)

+ func WithConsumeOptionsQueueAutoDelete(options *ConsumeOptions)

+ func WithConsumeOptionsQueueDurable(options *ConsumeOptions)

+ func WithConsumeOptionsQueueExclusive(options *ConsumeOptions)

+ func WithConsumeOptionsQueueNoWait(options *ConsumeOptions)

+ func WithConsumeOptionsQuorum(options *ConsumeOptions)

+ func WithConsumerOptionsLogging(options *ConsumerOptions)

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

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

+ func WithPublishOptionsImmediate(options *PublishOptions)

+ func WithPublishOptionsMandatory(options *PublishOptions)

+ func WithPublishOptionsPersistentDelivery(options *PublishOptions)

+ func WithPublisherOptionsLogging(options *PublisherOptions)

Mar 7, 2021

Changes in this version

type Consumer

+ func NewConsumer(url string, optionFuncs ...func(*ConsumerOptions)) (Consumer, error)

type Publisher

+ func NewPublisher(url string, optionFuncs ...func(*PublisherOptions)) (Publisher, <-chan Return, error)

Mar 7, 2021

Changes in this version

type ConsumeOptions

+ BindingArgs Table

+ BindingExchange string

+ BindingNoWait bool

+ Concurrency int

+ ConsumerArgs Table

+ ConsumerAutoAck bool

+ ConsumerExclusive bool

+ ConsumerName string

+ ConsumerNoLocal bool

+ ConsumerNoWait bool

+ QOSGlobal bool

+ QOSPrefetch int

+ QueueArgs Table

+ QueueAutoDelete bool

+ QueueDurable bool

+ QueueExclusive bool

+ QueueNoWait bool

type Consumer

+ func (consumer Consumer) StartConsuming(handler func(d Delivery) bool, queue string, routingKeys []string, ...) error

type ConsumerOptions

+ Logging bool

+ type PublisherOptions struct

+ Logging bool

Mar 7, 2021

Changes in this version

+ const Persistent

+ const Transient

+ type BindingOptions struct

+ Args Table

+ Exchange string

+ NoWait bool

+ type ConsumeOptions struct

+ BindingOptions BindingOptions

+ ConsumerOptions ConsumerOptions

+ Logging bool

+ QosOptions QosOptions

+ QueueOptions QueueOptions

+ type Consumer struct

+ func GetConsumer(url string, logging bool) (Consumer, error)

+ func (consumer Consumer) StartConsumers(handler func(d Delivery) bool, consumeOptions *ConsumeOptions, queue string, ...) error

+ type ConsumerOptions struct

+ Args Table

+ AutoAck bool

+ Exclusive bool

+ Name string

+ NoLocal bool

+ NoWait bool

+ type Delivery struct

+ type PublishOptions struct

+ ContentType string

+ DeliveryMode uint8

+ Exchange string

+ Immediate bool

+ Mandatory bool

+ type Publisher struct

+ func GetPublisher(url string, logging bool) (Publisher, <-chan Return, error)

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

+ type QosOptions struct

+ Concurrency int

+ Global bool

+ Prefetch int

+ type QueueOptions struct

+ Args Table

+ AutoDelete bool

+ Durable bool

+ Exclusive bool

+ NoWait bool

+ type Return struct

+ type Table map[string]interface