Struct Pool 

pub struct Pool<C: Connection> { /* private fields */ }

A connection pool for database connections.

The pool manages a collection of connections, reusing them across requests to avoid the overhead of establishing new connections.

Type Parameters

• C: The connection type, must implement Connection

Cancellation

Pool operations respect cancellation via the Cx context:

• acquire will return early if cancellation is requested
• Connections are properly cleaned up on cancellation

Implementations

impl<C: Connection> Pool<C>

pub fn new(config: PoolConfig) -> Self

Create a new connection pool with the given configuration.

pub fn config(&self) -> PoolConfig

Get the pool configuration.

pub fn stats(&self) -> PoolStats

Get the current pool statistics.

pub fn at_capacity(&self) -> bool

Check if the pool is at capacity.

pub fn is_closed(&self) -> bool

Check if the pool has been closed.

pub async fn acquire<F, Fut>( &self, cx: &Cx, factory: F, ) -> Outcome<PooledConnection<C>, Error>

where F: Fn() -> Fut, Fut: Future<Output = Outcome<C, Error>>,

Acquire a connection from the pool.

This method will:

1. Return an idle connection if one is available
2. Create a new connection if below capacity
3. Wait for a connection to become available (up to timeout)

Errors

Returns an error if:

• The pool is closed
• The acquire timeout is exceeded
• Cancellation is requested via the Cx context
• Connection validation fails (if test_on_checkout is enabled)

pub fn clear_idle(&self)

Close the pool, preventing new connections and closing all idle connections.

If the pool mutex is poisoned, this logs an error but still wakes waiters.

pub fn close(&self)

pub fn idle_count(&self) -> usize

Get the number of idle connections.

pub fn active_count(&self) -> usize

Get the number of active connections.

pub fn total_count(&self) -> usize

Get the total number of connections.