Struct ConnectionPool

pub struct ConnectionPool<T, P, C, V>
where
    T: Send + 'static,
    P: Send + Sync + Clone + 'static,
    C: Send + Sync + 'static,
    V: Send + Sync + 'static,
{ /* private fields */ }

Implementations

impl<T, P, C, V> ConnectionPool<T, P, C, V>

where C: ConnectionCreator<T, P> + Send + Sync + 'static, V: ConnectionValidator<T> + Send + Sync + 'static, T: Send + 'static, P: Send + Sync + Clone + 'static,

pub fn new( max_size: Option<usize>, max_idle_time: Option<Duration>, connection_timeout: Option<Duration>, cleanup_config: Option<CleanupConfig>, connection_params: P, connection_creator: C, connection_validator: V, ) -> Arc<Self>

pub async fn get_connection( self: Arc<Self>, ) -> Result<PooledStream<T, P, C, V>, PoolError<C::Error>>

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 ConnectionPool<TcpStream, String, TcpConnectionCreator, TcpConnectionValidator>

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