Struct PoolRegistry 

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

Hands out one ConnectionPool per key, built on first use. It is lazy: a pool is created on first access and is NOT opened, so it does no background maintenance unless you open it yourself.

Implementations

impl<K, T> PoolRegistry<K, T>

where K: Clone + Eq + Hash + Display, T: Clone + Eq + Hash + Send + Sync + 'static,

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

where F: Fn(&K) -> Box<dyn ConnectionFactory<T>> + Send + Sync + 'static,

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

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<ConnectionPool<T>, PoolError>

Returns the pool for key, creating it on first use. The returned pool is a cheap handle to the registry-owned pool.

pub 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.

pub fn close(&self)

Closes every pool and rejects further use.