queue

Documentation

Index

• type Definition
  • func NewDefinition(name, routingKey, exchange string, opts ...QueueOpt) *Definition
  • func (q Definition) CreateBindedQueue(ctx context.Context, channel *amqp.Channel) (*amqp.Queue, error)
• type QueueOpt
  • func WithAutoDelete(autoDelete bool) QueueOpt
  • func WithBindingArgs(args amqp.Table) QueueOpt
  • func WithDurable(durable bool) QueueOpt
  • func WithExclusive(ex bool) QueueOpt
  • func WithNoWait(noWait bool) QueueOpt
  • func WithQueueArgs(args amqp.Table) QueueOpt

Types

type Definition

type Definition struct {
	Name        string
	RoutingKey  string
	Exchange    string
	Durable     bool
	AutoDelete  bool
	Exclusive   bool
	NoWait      bool
	QueueArgs   amqp.Table
	BindingArgs amqp.Table
}

func NewDefinition

func NewDefinition(name, routingKey, exchange string, opts ...QueueOpt) *Definition

func (Definition) CreateBindedQueue

func (q Definition) CreateBindedQueue(ctx context.Context, channel *amqp.Channel) (*amqp.Queue, error)

type QueueOpt

type QueueOpt func(*Definition)

func WithAutoDelete

func WithAutoDelete(autoDelete bool) QueueOpt

func WithBindingArgs

func WithBindingArgs(args amqp.Table) QueueOpt

func WithDurable

func WithDurable(durable bool) QueueOpt

func WithExclusive

func WithExclusive(ex bool) QueueOpt

func WithNoWait

func WithNoWait(noWait bool) QueueOpt

func WithQueueArgs

func WithQueueArgs(args amqp.Table) QueueOpt