exchange_declare

package
Version: v0.0.0-...-be4923c Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Apr 29, 2021 License: MIT Imports: 3 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

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

Functions

This section is empty.

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

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
t or T : Toggle theme light dark auto
y or Y : Canonical URL