package
1.2.8
Repository: https://github.com/rifaniponk/amqp.git
Documentation: pkg.go.dev

# Functions

Attempts sets the maximum attempts to connect/reconnect.
No description provided by the author
No description provided by the author
No description provided by the author
No description provided by the author
No description provided by the author
Generic connection function.
No description provided by the author
Dial wraps amqp.Dial function and adds reconnection ability.
DialConfig wraps amqp.DialConfig function and adds reconnection ability.
DialTLS wraps amqp.DialTLS function and adds reconnection ability.
DialWithDialer wraps any Dialer and adds reconnection ability.
Set custom connection name, that will be displayed in management plugins.
No description provided by the author
Open wraps amqp.Open function and adds reconnection ability.
No description provided by the author
Set custom service name, that will be displayed in client information.
.
Directly set dial config.
WithContext allows use power of Context in connection loop.
Timeout sets delays for connection between attempts.
WithDelayBuilder changes delay mechanism between attempts.
WithLogger sets logger, which notifies about these events:.

# Variables

Common errors.
Common errors.
Common errors.
Common errors.
Common errors.

# Structs

No description provided by the author
Notifier notify receivers when something happen.
Signal is shortcut for struct{}.

# Interfaces

No description provided by the author

# Type aliases

ConnectionOption is a type which represents optional Connection's feature.
No description provided by the author
No description provided by the author
No description provided by the author