connection

Documentation

Index

• type Option
  • func WithBackoff(bo backoff.BackOff) Option
  • func WithConfig(cfg amqp.Config) Option
  • func WithDialAttemptCallback(fn func(error)) Option
  • func WithDialledCallback(fn func(*amqp.Connection)) Option
• type Redialer
  • func Dial(url string, ops ...Option) (*Redialer, error)
  • func (r *Redialer) Channel(ops ...channel.Option) (*channel.Reopener, error)

Types

type Option

type Option func(r *Redialer)

Option to configure Reconnector.

func WithBackoff

func WithBackoff(bo backoff.BackOff) Option

WithBackoff sets backoff function for reconnection. By default, uses backoff.NewExponentialBackOff.

func WithConfig

func WithConfig(cfg amqp.Config) Option

WithConfig uses provided cfg to specify a configuration for the transport and connection setup used during a connection open handshake. See more: https://pkg.go.dev/github.com/rabbitmq/amqp091-go@v1.8.0#DialConfig.

func WithDialAttemptCallback

func WithDialAttemptCallback(fn func(error)) Option

WithDialAttemptCallback registers a callback for any AMQP dial attempt result. Will call func with result for each attempt to dial AMQP.

func WithDialledCallback

func WithDialledCallback(fn func(*amqp.Connection)) Option

WithDialledCallback registers a callback for successful AMQP dial. Will call func with each created connection. Could be used to set up listeners for various evens (NotifyClose, NotifyFlow, etc.) after channel recreation.

type Redialer

type Redialer struct {
	*amqp.Connection
	// contains filtered or unexported fields
}

Redialer wraps connection to add re-dial capabilities. All methods of the regular channel are also available.

func Dial

func Dial(url string, ops ...Option) (*Redialer, error)

Dial is a regular amqp.Dial with re-dialing and backoff.

func (*Redialer) Channel

func (r *Redialer) Channel(ops ...channel.Option) (*channel.Reopener, error)

Channel create new channel.Reopener with channel re-open capabilities. Will re-dial if connection is closed. Access original channel with r.Connection.Channel().