Versions in this module Expand all Collapse all v1 v1.3.0 Jul 15, 2024 Changes in this version + func Dial(opts ...Option) (*amqp.Connection, error) + func NewConsumer(connCh <-chan *Connection, opts ...consumer.Option) (*consumer.Consumer, error) + func NewPublisher(connCh <-chan *Connection, opts ...publisher.Option) (*publisher.Publisher, error) + type AMQPConnection interface + Close func() error + NotifyClose func(chan *amqp.Error) chan *amqp.Error + type Connection struct + func (c *Connection) AMQPConnection() *amqp.Connection + func (c *Connection) NotifyLost() chan struct{} + type Dialer struct + func NewDialer(opts ...Option) (*Dialer, error) + func (c *Dialer) Close() + func (c *Dialer) Connection(ctx context.Context) (*amqp.Connection, error) + func (c *Dialer) ConnectionCh() <-chan *Connection + func (c *Dialer) Consumer(opts ...consumer.Option) (*consumer.Consumer, error) + func (c *Dialer) Notify(stateCh chan State) <-chan State + func (c *Dialer) NotifyClosed() <-chan struct{} + func (c *Dialer) Publisher(opts ...publisher.Option) (*publisher.Publisher, error) + type Option func(c *Dialer) + func WithAMQPDial(dial func(url string, c amqp.Config) (AMQPConnection, error)) Option + func WithConnectionProperties(props amqp.Table) Option + func WithContext(ctx context.Context) Option + func WithLogger(l logger.Logger) Option + func WithNotify(stateCh chan State) Option + func WithRetryPeriod(dur time.Duration) Option + func WithTLS(tlsConfig *tls.Config) Option + func WithURL(urls ...string) Option + type Ready struct + type State struct + Ready *Ready + Unready *Unready + type Unready struct + Err error
Go to main page