Struct ConnectionPool 

pub struct ConnectionPool<F>
where
    F: ConnectionFactory,
{ /* private fields */ }

Async connection pool keyed by stable host identity and exact topology revision.

Implementations

impl<F> ConnectionPool<F>

where F: ConnectionFactory,

pub fn new(factory: Arc<F>) -> Self

Creates an empty pool using the supplied connection factory.

pub async fn get_or_connect( &self, host: &HostRecord, cancellation: &CancellationToken, ) -> FleetResult<Arc<F::Connection>>

Returns an existing exact-revision connection or opens it once.

Concurrent cold-cache callers for the same revision share one initialization cell. The map lock is never held across an await.

pub async fn invalidate_host(&self, host: &HostId) -> FleetResult<usize>

Invalidates every cached revision for one host and closes each handle.

pub async fn retain_snapshot( &self, snapshot: &TopologySnapshot, ) -> FleetResult<usize>

Evicts connections absent from the current topology snapshot.

pub async fn shutdown(&self) -> FleetResult<usize>

Closes and removes every initialized connection.

pub async fn len(&self) -> usize

Returns cached revision-key count, including in-flight initializations.

pub async fn is_empty(&self) -> bool

Returns whether no revision keys are cached.