amqp

Documentation

Index

• Constants
• func Dial(url string) (*amqp.Connection, *amqp.Channel, error)
• func IsNotFound(err error) bool
• func NewChannelManager(log logr.Logger, url string) (*channelManager, error)
• func NewPublisher(log logr.Logger, url string) (*publisher, error)
• type ChannelManager
• type PublishOptions
• type Publisher

Constants

const (
	AppID             = "hephaestus"
	MandatoryDelivery = true
	ImmediateDelivery = false

	ExchangeType       = "direct"
	ExchangeDurable    = true
	ExchangeAutoDelete = false
	ExchangeInternal   = false
	ExchangeNoWait     = false

	QueueDurable    = true
	QueueAutoDelete = false
	QueueExclusive  = false
	QueueNoWait     = false
)

Functions

func Dial

func Dial(url string) (*amqp.Connection, *amqp.Channel, error)

func IsNotFound

func IsNotFound(err error) bool

func NewChannelManager

func NewChannelManager(log logr.Logger, url string) (*channelManager, error)

func NewPublisher

func NewPublisher(log logr.Logger, url string) (*publisher, error)

Types

type ChannelManager

type ChannelManager interface {
	Channel() *amqp.Channel
	Close() error
}

type PublishOptions

type PublishOptions struct {
	ExchangeName string
	QueueName    string
	ContentType  string
	Body         []byte
}

type Publisher

type Publisher interface {
	Publish(PublishOptions) error
	Close() error
}