Versions in this module Expand all Collapse all v0 v0.14.1 May 17, 2024 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 WithConsumerOptionsExchangeOptions(exchangeOptions ExchangeOptions) func(*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 WithPublisherOptionsConfirm(options *PublisherOptions) + 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, queue string, optionFuncs ...func(*ConsumerOptions)) (*Consumer, error) + func (consumer *Consumer) Close() + func (consumer *Consumer) Run(handler Handler) error + type ConsumerOptions struct + Concurrency int + ExchangeOptions []ExchangeOptions + Logger logger.Logger + PreDeclare bool + QOSGlobal bool + QOSPrefetch int + QueueOptions QueueOptions + RabbitConsumerOptions RabbitConsumerOptions + type Delivery struct + type ExchangeOptions struct + Args Table + AutoDelete bool + Bindings []Binding + 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 + ConfirmMode bool + 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
Go to main page