topology

package

v1.7.0 Latest Latest Go to latest Published: Jan 15, 2025 License: MIT Imports: 3 Imported by: 1

Details

View Source

const (
	DLXName   = "default-dead-letter"
	DLQSuffix = "DLQ"
)

This section is empty.

This section is empty.

type Binding struct {
	ExchangeName string
	QueueName    string
	RoutingKey   string
	Args         amqp.Table
}

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

type Declarations struct {
	Exchanges []*Exchange
	Queues    []*Queue
	Bindings  []*Binding
}

func Compile(cfg Declarations) Declarations

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

func WithTopicExchange(name string) DeclarationsOption

type Exchange struct {
	Name string
	Type string
	Args amqp.Table
}

func NewDirectExchange(name string) *Exchange

func NewFanoutExchange(name string) *Exchange

func NewTopicExchange(name string) *Exchange

type Queue struct {
	Name        string
	DLQ         bool
	Durable     bool
	AutoDelete  bool
	RetryPolicy *retry.Policy
	Args        amqp.Table
}

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

type QueueOption func(q *Queue)

func WithAutoDelete(value bool) QueueOption

func WithDLQ(value bool) QueueOption

func WithDurable(value bool) QueueOption

func WithQueueArg(key string, value any) QueueOption

func WithRetryPolicy(policy retry.Policy) QueueOption