topology

May 24, 2023

Changes in this version

+ const DLQSuffix

+ const DLXName

type Declarations

+ func Compile(cfg Declarations) Declarations

type Queue

+ RetryPolicy *retry.Policy

type QueueOption

+ func WithRetryPolicy(policy retry.Policy) QueueOption

Feb 9, 2023

Changes in this version

type Queue

+ AutoDelete bool

+ Durable bool

type QueueOption

+ func WithAutoDelete(value bool) QueueOption

+ func WithDurable(value bool) QueueOption

Jan 12, 2022

Changes in this version

type DeclarationsOption

+ func WithTopicExchange(name string) DeclarationsOption

type Exchange

+ func NewTopicExchange(name string) *Exchange

Jan 9, 2022

Changes in this version

+ type Binding struct

+ Args amqp.Table

+ ExchangeName string

+ QueueName string

+ RoutingKey string

+ func NewBinding(exchangeName string, queueName string, routingKey string) *Binding

+ type Declarations struct

+ Bindings []*Binding

+ Exchanges []*Exchange

+ Queues []*Queue

+ func New(opts ...DeclarationsOption) Declarations

+ type DeclarationsOption func(d *Declarations)

+ func WithBinding(exchangeName string, queueName string, routingKey string) DeclarationsOption

+ func WithDirectExchange(name string) DeclarationsOption

+ func WithFanoutExchange(name string) DeclarationsOption

+ func WithQueue(name string, opts ...QueueOption) DeclarationsOption

+ type Exchange struct

+ Args amqp.Table

+ Name string

+ Type string

+ func NewDirectExchange(name string) *Exchange

+ func NewFanoutExchange(name string) *Exchange

+ type Queue struct

+ Args amqp.Table

+ DLQ bool

+ Name string

+ func NewQueue(name string, opts ...QueueOption) *Queue

+ type QueueOption func(q *Queue)

+ func WithDLQ(value bool) QueueOption

+ func WithQueueArg(key string, value interface{}) QueueOption