exchange_declare

Documentation

Index

• Variables
• type ArgsDecl
  • func (a ArgsDecl) Defaults() End
  • func (a ArgsDecl) WithArgs(args amqp.Table) ErrorChanDecl
• type AutoDeleteDecl
  • func (a AutoDeleteDecl) Defaults() End
  • func (a AutoDeleteDecl) WithAutoDelete(autodelete bool) InternalDecl
  • func (a AutoDeleteDecl) WithDefaultAutoDelete() InternalDecl
• type BindDecl
  • func (b BindDecl) AndDeclareQueue(queueName string) queue_declaration.NameDecl
• type End
  • func (e End) Build(ch *chamqp.Channel) BindDecl
  • func (e End) BuildSpec() chamqp.ExchangeDeclareSpec
• type ErrorChanDecl
  • func (e ErrorChanDecl) Defaults() End
  • func (e ErrorChanDecl) WithErrorChan(errorChan chan error) End
• type InternalDecl
  • func (i InternalDecl) Defaults() End
  • func (i InternalDecl) WithDefaultInternal() NoWaitDecl
  • func (i InternalDecl) WithInternal(internal bool) NoWaitDecl
• type KindDecl
  • func (k KindDecl) Defaults() End
  • func (k KindDecl) WithDefaultDurable() AutoDeleteDecl
  • func (k KindDecl) WithDurable(durable bool) AutoDeleteDecl
• type NameDecl
  • func DeclareExchange(exchangeName string) NameDecl
  • func (n NameDecl) Defaults() End
  • func (n NameDecl) WithDefaultKind() KindDecl
  • func (n NameDecl) WithKind(kind string) KindDecl
• type NoWaitDecl
  • func (n NoWaitDecl) Defaults() End
  • func (n NoWaitDecl) WithDefaultNoWait() ArgsDecl
  • func (n NoWaitDecl) WithNoWait(nowait bool) ArgsDecl

Variables

var Defaults = chamqp.ExchangeDeclareSpec{
	Name:       "",
	Kind:       "topic",
	Durable:    true,
	AutoDelete: false,
	Internal:   false,
	NoWait:     false,
	Args:       nil,
	ErrorChan:  nil,
}

Types

type ArgsDecl

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

func (ArgsDecl) Defaults

func (a ArgsDecl) Defaults() End

func (ArgsDecl) WithArgs

func (a ArgsDecl) WithArgs(args amqp.Table) ErrorChanDecl

type AutoDeleteDecl

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

func (AutoDeleteDecl) Defaults

func (a AutoDeleteDecl) Defaults() End

func (AutoDeleteDecl) WithAutoDelete

func (a AutoDeleteDecl) WithAutoDelete(autodelete bool) InternalDecl

func (AutoDeleteDecl) WithDefaultAutoDelete

func (a AutoDeleteDecl) WithDefaultAutoDelete() InternalDecl

type BindDecl

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

func (BindDecl) AndDeclareQueue

func (b BindDecl) AndDeclareQueue(queueName string) queue_declaration.NameDecl

type End

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

func (End) Build

func (e End) Build(ch *chamqp.Channel) BindDecl

func (End) BuildSpec

func (e End) BuildSpec() chamqp.ExchangeDeclareSpec

type ErrorChanDecl

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

func (ErrorChanDecl) Defaults

func (e ErrorChanDecl) Defaults() End

func (ErrorChanDecl) WithErrorChan

func (e ErrorChanDecl) WithErrorChan(errorChan chan error) End

type InternalDecl

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

func (InternalDecl) Defaults

func (i InternalDecl) Defaults() End

func (InternalDecl) WithDefaultInternal

func (i InternalDecl) WithDefaultInternal() NoWaitDecl

func (InternalDecl) WithInternal

func (i InternalDecl) WithInternal(internal bool) NoWaitDecl

type KindDecl

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

func (KindDecl) Defaults

func (k KindDecl) Defaults() End

func (KindDecl) WithDefaultDurable

func (k KindDecl) WithDefaultDurable() AutoDeleteDecl

func (KindDecl) WithDurable

func (k KindDecl) WithDurable(durable bool) AutoDeleteDecl

type NameDecl

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

func DeclareExchange

func DeclareExchange(exchangeName string) NameDecl

func (NameDecl) Defaults

func (n NameDecl) Defaults() End

func (NameDecl) WithDefaultKind

func (n NameDecl) WithDefaultKind() KindDecl

func (NameDecl) WithKind

func (n NameDecl) WithKind(kind string) KindDecl

type NoWaitDecl

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

func (NoWaitDecl) Defaults

func (n NoWaitDecl) Defaults() End

func (NoWaitDecl) WithDefaultNoWait

func (n NoWaitDecl) WithDefaultNoWait() ArgsDecl

func (NoWaitDecl) WithNoWait

func (n NoWaitDecl) WithNoWait(nowait bool) ArgsDecl