Documentation ¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type Dialer ¶
type Dialer = func(endpoint string) (*amqp.Connection, error)
Dialer is the callback function that provides an AMQP connection.
type FairPool ¶
type FairPool struct { Dialer Dialer Endpoints []url.URL RedialInterval time.Duration AcquireTimeout time.Duration OnBrokerOpen func(url.URL) OnBrokerClose func(url.URL) OnBrokerError func(error) // contains filtered or unexported fields }
FairPool ...
type Pool ¶
type Pool interface { Launch() Shutdown() Acquire() *amqp.Connection Release(*amqp.Connection) }
Pool ...
Click to show internal directories.
Click to hide internal directories.