Struct ConnectionPool 

pub struct ConnectionPool<T> { /* private fields */ }

Generic connection pool for any transport type

Implementations

impl<T: Send + 'static> ConnectionPool<T>

pub fn new( factory: Arc<dyn ConnectionFactory<T>>, config: PoolConfig, ) -> Result<Self>

Create a new connection pool

pub async fn acquire(&self) -> Result<PooledConnectionGuard<T>>

Get a connection from the pool or create a new one

pub fn metrics(&self) -> Arc<PoolMetrics>

Get pool metrics

pub async fn size(&self) -> usize

Current number of connections in pool

pub async fn clear(&self)

Clear all connections from the pool

pub fn config(&self) -> &PoolConfig

Get pool configuration