queue_declaration

Documentation

Index

• type ArgsDecl
  • func (a ArgsDecl) Defaults() End
  • func (a ArgsDecl) WithDefaultQueueChan() QueueChanDecl
  • func (a ArgsDecl) WithQueueChan(queueChan chan amqp.Queue) QueueChanDecl
• type AutoDelete
  • func (a AutoDelete) Defaults() End
  • func (a AutoDelete) WithDefaultExclusive() ExclusiveDecl
  • func (a AutoDelete) WithExclusive(exclusive bool) ExclusiveDecl
• type BindDecl
  • func (b BindDecl) AndBind() queue_bind.NameDecl
  • func (b BindDecl) AndBindWithExchange() queue_bind.ExchangeDecl
• type DurableDecl
  • func (d DurableDecl) Defaults() End
  • func (d DurableDecl) WithAutoDelete(autodelete bool) AutoDelete
  • func (d DurableDecl) WithDefaultDurable() AutoDelete
• type End
  • func (e End) Build(ch *chamqp.Channel) BindDecl
  • func (e End) BuildSpec() chamqp.QueueDeclareSpec
• type ExclusiveDecl
  • func (e ExclusiveDecl) Defaults() End
  • func (e ExclusiveDecl) WithDefaultNoWait() NoWaitDecl
  • func (e ExclusiveDecl) WithNoWait(noWait bool) NoWaitDecl
• type NameDecl
  • func DeclareQueue(name string) NameDecl
  • func DeclareQueueWithChan(name string, exchangeName *string) NameDecl
  • func (n NameDecl) Defaults() End
  • func (n NameDecl) WithDefaultDurable() DurableDecl
  • func (n NameDecl) WithDurable(durable bool) DurableDecl
• type NoWaitDecl
  • func (n NoWaitDecl) Defaults() End
  • func (n NoWaitDecl) WithArgs(args amqp.Table) ArgsDecl
  • func (n NoWaitDecl) WithDefaultArgs() ArgsDecl
• type QueueChanDecl
  • func (q QueueChanDecl) Defaults() End
  • func (q QueueChanDecl) WithDefaultErrorChan() End
  • func (q QueueChanDecl) WithErrorChan(errorChan chan error) End

Types

type ArgsDecl

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

func (ArgsDecl) Defaults

func (a ArgsDecl) Defaults() End

func (ArgsDecl) WithDefaultQueueChan

func (a ArgsDecl) WithDefaultQueueChan() QueueChanDecl

func (ArgsDecl) WithQueueChan

func (a ArgsDecl) WithQueueChan(queueChan chan amqp.Queue) QueueChanDecl

type AutoDelete

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

func (AutoDelete) Defaults

func (a AutoDelete) Defaults() End

func (AutoDelete) WithDefaultExclusive

func (a AutoDelete) WithDefaultExclusive() ExclusiveDecl

func (AutoDelete) WithExclusive

func (a AutoDelete) WithExclusive(exclusive bool) ExclusiveDecl

type BindDecl

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

func (BindDecl) AndBind

func (b BindDecl) AndBind() queue_bind.NameDecl

func (BindDecl) AndBindWithExchange

func (b BindDecl) AndBindWithExchange() queue_bind.ExchangeDecl

type DurableDecl

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

func (DurableDecl) Defaults

func (d DurableDecl) Defaults() End

func (DurableDecl) WithAutoDelete

func (d DurableDecl) WithAutoDelete(autodelete bool) AutoDelete

func (DurableDecl) WithDefaultDurable

func (d DurableDecl) WithDefaultDurable() AutoDelete

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.QueueDeclareSpec

type ExclusiveDecl

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

func (ExclusiveDecl) Defaults

func (e ExclusiveDecl) Defaults() End

func (ExclusiveDecl) WithDefaultNoWait

func (e ExclusiveDecl) WithDefaultNoWait() NoWaitDecl

func (ExclusiveDecl) WithNoWait

func (e ExclusiveDecl) WithNoWait(noWait bool) NoWaitDecl

type NameDecl

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

func DeclareQueue

func DeclareQueue(name string) NameDecl

func DeclareQueueWithChan

func DeclareQueueWithChan(name string, exchangeName *string) NameDecl

func (NameDecl) Defaults

func (n NameDecl) Defaults() End

func (NameDecl) WithDefaultDurable

func (n NameDecl) WithDefaultDurable() DurableDecl

func (NameDecl) WithDurable

func (n NameDecl) WithDurable(durable bool) DurableDecl

type NoWaitDecl

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

func (NoWaitDecl) Defaults

func (n NoWaitDecl) Defaults() End

func (NoWaitDecl) WithArgs

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

func (NoWaitDecl) WithDefaultArgs

func (n NoWaitDecl) WithDefaultArgs() ArgsDecl

type QueueChanDecl

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

func (QueueChanDecl) Defaults

func (q QueueChanDecl) Defaults() End

func (QueueChanDecl) WithDefaultErrorChan

func (q QueueChanDecl) WithDefaultErrorChan() End

func (QueueChanDecl) WithErrorChan

func (q QueueChanDecl) WithErrorChan(errorChan chan error) End