rabbitmq

Documentation

Index

• type AmqpClient
  • func NewAmqpClient(logger *zap.Logger) AmqpClient
• type Channel
• type Connection
• type DeferredConfirmation
• type DialConfig

Types

type AmqpClient

type AmqpClient interface {
	DialConfig(config DialConfig) (Connection, error)
}

func NewAmqpClient

func NewAmqpClient(logger *zap.Logger) AmqpClient

type Channel

type Channel interface {
	Confirm(noWait bool) error
	PublishWithDeferredConfirmWithContext(ctx context.Context, exchange, key string, mandatory, immediate bool, msg amqp.Publishing) (DeferredConfirmation, error)
	IsClosed() bool
	Close() error
}

type Connection

type Connection interface {
	ReconnectIfUnhealthy() error
	IsClosed() bool
	Channel() (Channel, error)
	NotifyClose(receiver chan *amqp.Error) chan *amqp.Error
	Close() error
}

type DeferredConfirmation

type DeferredConfirmation interface {
	Done() <-chan struct{}
	Acked() bool
}

type DialConfig

type DialConfig struct {
	URL               string
	Vhost             string
	Auth              amqp.Authentication
	ConnectionTimeout time.Duration
	Heartbeat         time.Duration
	TLS               *tls.Config
	ConnectionName    string
}