exchange

Documentation

Index

• type Definition
  • func NewDefinition(name string, exchangeType ExchangeType, opts ...ExchangeOpt) *Definition
  • func (e Definition) CreateExchange(ctx context.Context, channel *amqp.Channel) error
• type ExchangeOpt
  • func WithArgs(args amqp.Table) ExchangeOpt
  • func WithAutoDelete(autoDelete bool) ExchangeOpt
  • func WithDurable(durable bool) ExchangeOpt
  • func WithInternal(internal bool) ExchangeOpt
  • func WithNoWait(noWait bool) ExchangeOpt
• type ExchangeType
  • func ExchangeTypeFromString(s string) (ExchangeType, error)
  • func (e ExchangeType) String() string

Types

type Definition

type Definition struct {
	Name       string
	Type       ExchangeType
	Durable    bool
	AutoDelete bool
	Internal   bool
	NoWait     bool
	Args       amqp.Table
}

func NewDefinition

func NewDefinition(name string, exchangeType ExchangeType, opts ...ExchangeOpt) *Definition

func (Definition) CreateExchange

func (e Definition) CreateExchange(ctx context.Context, channel *amqp.Channel) error

type ExchangeOpt

type ExchangeOpt func(*Definition)

func WithArgs

func WithArgs(args amqp.Table) ExchangeOpt

func WithAutoDelete

func WithAutoDelete(autoDelete bool) ExchangeOpt

func WithDurable

func WithDurable(durable bool) ExchangeOpt

func WithInternal

func WithInternal(internal bool) ExchangeOpt

func WithNoWait

func WithNoWait(noWait bool) ExchangeOpt

type ExchangeType

type ExchangeType int

const (
	ExchangeTypeDirect ExchangeType = iota
	ExchangeTypeFanout
	ExchangeTypeTopic
	ExchangeTypeHeaders
)

func ExchangeTypeFromString

func ExchangeTypeFromString(s string) (ExchangeType, error)

func (ExchangeType) String

func (e ExchangeType) String() string