Versions in this module Expand all Collapse all v1 v1.0.0 Nov 2, 2022 Changes in this version + const Persistent + const Transient + func WithConsumeDeclareOptions(declareOptionsFuncs ...func(options *DeclareOptions)) func(*ConsumeOptions) + func WithConsumeOptionsConcurrency(concurrency int) func(*ConsumeOptions) + func WithConsumeOptionsConsumerAutoAck(autoAck bool) 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 WithConsumerOptionsLogger(log Logger) func(options *ConsumerOptions) + func WithConsumerOptionsLogging(options *ConsumerOptions) + func WithConsumerOptionsReconnectInterval(reconnectInterval time.Duration) func(options *ConsumerOptions) + func WithDeclareBindingArgs(args Table) func(*DeclareOptions) + func WithDeclareBindingNoWait(options *DeclareOptions) + func WithDeclareBindings(bindings []Binding) func(*DeclareOptions) + func WithDeclareBindingsForRoutingKeys(routingKeys []string) func(*DeclareOptions) + func WithDeclareExchange(settings *ExchangeOptions) func(*DeclareOptions) + func WithDeclareExchangeArgs(args Table) func(*DeclareOptions) + func WithDeclareExchangeAutoDelete(options *DeclareOptions) + func WithDeclareExchangeDurable(options *DeclareOptions) + func WithDeclareExchangeInternal(options *DeclareOptions) + func WithDeclareExchangeKind(kind string) func(*DeclareOptions) + func WithDeclareExchangeName(name string) func(*DeclareOptions) + func WithDeclareExchangeNoDeclare(options *DeclareOptions) + func WithDeclareExchangeNoWait(options *DeclareOptions) + func WithDeclareQueue(settings *QueueOptions) func(*DeclareOptions) + func WithDeclareQueueArgs(args Table) func(*DeclareOptions) + func WithDeclareQueueAutoDelete(options *DeclareOptions) + func WithDeclareQueueDurable(options *DeclareOptions) + func WithDeclareQueueExclusive(options *DeclareOptions) + func WithDeclareQueueName(name string) func(*DeclareOptions) + func WithDeclareQueueNoDeclare(options *DeclareOptions) + func WithDeclareQueueNoWait(options *DeclareOptions) + func WithDeclareQueueQuorum(options *DeclareOptions) + 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 WithPublisherDeclareOptions(declareOptionsFuncs ...func(options *DeclareOptions)) func(*PublisherOptions) + func WithPublisherOptionsLogger(log Logger) func(options *PublisherOptions) + func WithPublisherOptionsLogging(options *PublisherOptions) + func WithPublisherOptionsReconnectInterval(reconnectInterval time.Duration) func(options *PublisherOptions) + type Action int + const Ack + const NackDiscard + const NackRequeue + type Binding struct + ExchangeName string + QueueName string + RoutingKey string + type BindingOption struct + Args Table + NoWait bool + type Config amqp.Config + type Confirmation struct + ReconnectionCount int + type ConsumeOptions struct + Concurrency int + ConsumerArgs Table + ConsumerAutoAck bool + ConsumerExclusive bool + ConsumerName string + ConsumerNoLocal bool + ConsumerNoWait bool + QOSGlobal bool + QOSPrefetch int + QueueName string + type Consumer struct + func NewConsumer(url string, config Config, optionFuncs ...func(*ConsumerOptions)) (Consumer, error) + func (consumer Consumer) Close() error + func (consumer Consumer) StartConsuming(handler Handler, queue string, optionFuncs ...func(*ConsumeOptions)) error + type ConsumerOptions struct + Logger Logger + ReconnectInterval time.Duration + type DeclareOptions struct + Bindings []Binding + Exchange *ExchangeOptions + Queue *QueueOptions + func (o *DeclareOptions) SetBindings(routingKeys []string, opt BindingOption) + type Delivery struct + type ExchangeOptions struct + Args Table + AutoDelete bool + Durable bool + Internal bool + Kind string + Name string + NoWait bool + Passive bool + type Handler func(d Delivery) (action Action) + type Logger interface + Debugf func(string, ...interface{}) + Errorf func(string, ...interface{}) + Fatalf func(string, ...interface{}) + Infof func(string, ...interface{}) + Tracef func(string, ...interface{}) + Warnf func(string, ...interface{}) + 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(url string, config Config, optionFuncs ...func(*PublisherOptions)) (*Publisher, error) + func (publisher *Publisher) NotifyPublish() <-chan Confirmation + func (publisher *Publisher) NotifyReturn() <-chan Return + func (publisher *Publisher) Publish(data []byte, routingKeys []string, optionFuncs ...func(*PublishOptions)) error + func (publisher Publisher) Close() error + type PublisherOptions struct + Logger Logger + ReconnectInterval time.Duration + type QueueOptions struct + Args Table + AutoDelete bool + Durable bool + Exclusive bool + Name string + NoWait bool + Passive bool + type Return struct + type Table map[string]interface
Go to main page