Struct Pool 

pub struct Pool { /* private fields */ }

A pool of supervised AMQP connections.

Implementations

impl Pool

pub fn builder(url: impl Into<String>) -> PoolBuilder

Start building a pool.

pub fn size(&self) -> usize

The number of slots in the pool.

pub async fn acquire(&self) -> Result<Arc<Connection>, ConnectError>

Acquire a healthy connection, re-establishing a dead slot if needed.

Trait Implementations

impl Clone for Pool

fn clone(&self) -> Pool

Returns a duplicate of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.

impl Debug for Pool

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.