queue_bind

Documentation

Index

• Variables
• type ArgsDecl
  • func (a ArgsDecl) Defaults() ErrorChanDecl
  • func (a ArgsDecl) WithDefaultErrorChannel() ErrorChanDecl
  • func (a ArgsDecl) WithErrorChannel(channel chan error) ErrorChanDecl
• type ConsumeDecl
  • func (c ConsumeDecl) AndConsume() consume.QueueDecl
• type ErrorChanDecl
  • func (e ErrorChanDecl) Build(channel *chamqp.Channel) ConsumeDecl
  • func (e ErrorChanDecl) BuildSpec() chamqp.QueueBindSpec
• type ExchangeDecl
  • func BindQueueWithExchange(queueName, exchange string) ExchangeDecl
  • func (n ExchangeDecl) WithRoutingKey(routingKey string) KeyDecl
• type KeyDecl
  • func (e KeyDecl) Defaults() ErrorChanDecl
  • func (e KeyDecl) WithDefaultNoWait() NoWaitDecl
  • func (e KeyDecl) WithNoWait(noWait bool) NoWaitDecl
• type NameDecl
  • func BindQueue(queueName string) NameDecl
  • func (k NameDecl) WithExchange(exchangeName string) ExchangeDecl
• type NoWaitDecl
  • func (n NoWaitDecl) Defaults() ErrorChanDecl
  • func (n NoWaitDecl) WithArgs(args amqp.Table) ArgsDecl
  • func (n NoWaitDecl) WithDefaultArgs() ArgsDecl

Variables

var Defaults = chamqp.QueueBindSpec{
	Name:      "",
	Key:       "",
	Exchange:  "",
	NoWait:    false,
	Args:      nil,
	ErrorChan: nil,
}

Types

type ArgsDecl

type ArgsDecl struct {
	// contains filtered or unexported fields
}

func (ArgsDecl) Defaults

func (a ArgsDecl) Defaults() ErrorChanDecl

func (ArgsDecl) WithDefaultErrorChannel

func (a ArgsDecl) WithDefaultErrorChannel() ErrorChanDecl

func (ArgsDecl) WithErrorChannel

func (a ArgsDecl) WithErrorChannel(channel chan error) ErrorChanDecl

type ConsumeDecl

type ConsumeDecl struct {
	// contains filtered or unexported fields
}

func (ConsumeDecl) AndConsume

func (c ConsumeDecl) AndConsume() consume.QueueDecl

type ErrorChanDecl

type ErrorChanDecl struct {
	// contains filtered or unexported fields
}

func (ErrorChanDecl) Build

func (e ErrorChanDecl) Build(channel *chamqp.Channel) ConsumeDecl

func (ErrorChanDecl) BuildSpec

func (e ErrorChanDecl) BuildSpec() chamqp.QueueBindSpec

type ExchangeDecl

type ExchangeDecl struct {
	// contains filtered or unexported fields
}

func BindQueueWithExchange

func BindQueueWithExchange(queueName, exchange string) ExchangeDecl

func (ExchangeDecl) WithRoutingKey

func (n ExchangeDecl) WithRoutingKey(routingKey string) KeyDecl

type KeyDecl

type KeyDecl struct {
	// contains filtered or unexported fields
}

func (KeyDecl) Defaults

func (e KeyDecl) Defaults() ErrorChanDecl

func (KeyDecl) WithDefaultNoWait

func (e KeyDecl) WithDefaultNoWait() NoWaitDecl

func (KeyDecl) WithNoWait

func (e KeyDecl) WithNoWait(noWait bool) NoWaitDecl

type NameDecl

type NameDecl struct {
	// contains filtered or unexported fields
}

func BindQueue

func BindQueue(queueName string) NameDecl

func (NameDecl) WithExchange

func (k NameDecl) WithExchange(exchangeName string) ExchangeDecl

type NoWaitDecl

type NoWaitDecl struct {
	// contains filtered or unexported fields
}

func (NoWaitDecl) Defaults

func (n NoWaitDecl) Defaults() ErrorChanDecl

func (NoWaitDecl) WithArgs

func (n NoWaitDecl) WithArgs(args amqp.Table) ArgsDecl

func (NoWaitDecl) WithDefaultArgs

func (n NoWaitDecl) WithDefaultArgs() ArgsDecl