Struct ConnectionPool 

pub struct ConnectionPool<M: ConnectionManager> { /* private fields */ }

Connection pool

Implementations

impl<M> ConnectionPool<M>

where M: ConnectionManager + Send + Sync + Clone + 'static,

pub fn new( max_size: Option<usize>, max_idle_time: Option<Duration>, connection_timeout: Option<Duration>, cleanup_config: Option<CleanupConfig>, manager: M, ) -> Arc<Self>

Create a new connection pool

pub async fn get_connection( self: Arc<Self>, ) -> Result<ManagedConnection<M>, PoolError<M::Error>>

Get a connection from the pool

pub fn outstanding_count(&self) -> usize

pub async fn pool_size(&self) -> usize

pub fn max_size(&self) -> usize

pub async fn stop_cleanup_task(&self)

Stop the background cleanup task

pub async fn restart_cleanup_task(&self, cleanup_config: CleanupConfig)

Restart the background cleanup task with new configuration

impl<A> ConnectionPool<TcpConnectionManager<A>>

where A: ToSocketAddrs + Send + Sync + Clone + 'static,

pub fn new_tcp( max_size: Option<usize>, max_idle_time: Option<Duration>, connection_timeout: Option<Duration>, cleanup_config: Option<CleanupConfig>, address: A, ) -> Arc<Self>

Create a new TCP connection pool