amqp

Documentation

Index

• Constants
• func Dial(url string) (*amqp.Connection, *amqp.Channel, error)
• func IsNotFound(err error) bool
• type ChannelManager
• type Client
  • func NewPublisher(log logr.Logger, url string) (*Client, error)
  • func (p *Client) Close() error
  • func (p *Client) Publish(ctx context.Context, opts PublishOptions) error
• type Manager
  • func NewChannelManager(log logr.Logger, url string) (*Manager, error)
  • func (m *Manager) Channel() *amqp.Channel
  • func (m *Manager) Close() error
• 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

Types

type ChannelManager

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

type Client

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

func NewPublisher

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

func (*Client) Close

func (p *Client) Close() error

func (*Client) Publish

func (p *Client) Publish(ctx context.Context, opts PublishOptions) error

type Manager

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

func NewChannelManager

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

func (*Manager) Channel

func (m *Manager) Channel() *amqp.Channel

func (*Manager) Close

func (m *Manager) 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
}