Struct AsyncPoolRegistry 

pub struct AsyncPoolRegistry<K, T, F> { /* private fields */ }

Hands out one AsyncConnectionPool per key, built on first use. Lazy: pools are not opened automatically.

Implementations

impl<K, T, F> AsyncPoolRegistry<K, T, F>

where K: Clone + Eq + Hash + Display, T: Clone + Eq + Hash + Send + Sync + 'static, F: AsyncConnectionFactory<T> + 'static,

pub fn new<Fun>(factory_for: Fun, config: PoolConfig) -> Self

where Fun: Fn(&K) -> F + Send + Sync + 'static,

Builds a registry. factory_for makes the factory for a given key; config is shared.

pub fn with_clock(self, clock: Arc<dyn Clock>) -> Self

Shares clock with every pool the registry creates.

pub fn with_listeners(self, listeners: Vec<Arc<dyn PoolListener<T>>>) -> Self

Shares listeners with every pool the registry creates.

pub fn pool(&self, key: &K) -> Result<AsyncConnectionPool<T, F>, PoolError>

Returns the pool for key, creating it on first use.

pub async fn close(&self)

Closes every pool and rejects further use.

pub async fn with_connection<R>( &self, key: &K, timeout: Timeout, f: impl FnOnce(&T) -> R, ) -> Result<R, PoolError>

Borrows a connection from the pool for key for the duration of f.