Struct Pool 

pub struct Pool { /* private fields */ }

A fixed-size connection pool with round-robin dispatch.

All slots start disconnected. Call connect_all() for eager startup, or let client() lazily reconnect on demand.

Implementations

impl Pool

pub fn new(config: PoolConfig) -> Self

Create a new pool. All slots start disconnected.

pub async fn connect_all(&mut self) -> Result<(), Error>

Eagerly connect all slots. Returns an error if any connection fails.

pub async fn client(&mut self) -> Result<Client, Error>

Get a Client bound to the next healthy connection.

Advances the round-robin cursor and returns a client for a connected slot. Disconnected slots are lazily reconnected. If all slots fail, returns Error::AllConnectionsFailed.

pub fn mark_disconnected(&mut self, conn: ConnCtx)

Mark a connection as dead after a ConnectionClosed error.

Matches by ConnCtx::token() and sets the slot to disconnected. The next client() call will lazily reconnect.

pub fn close_all(&mut self)

Close all connections and reset slots to disconnected.

pub fn connected_count(&self) -> usize

Number of currently connected slots.

pub fn pool_size(&self) -> usize

Total number of slots in the pool.