Struct ClientPool 

pub struct ClientPool<M: ClientManager> { /* private fields */ }

A bounded process-local pool of protocol-specific clients.

Implementations

impl<M: ClientManager> ClientPool<M>

pub fn new(manager: M, options: PoolOptions) -> Result<Self, OptionsError>

Construct an empty pool. This performs no network IO.

pub async fn acquire( &self, active_policy: ActiveRequestPolicy, ) -> Result<ClientLease<M>, AcquireError<M::Error>>

Acquire one client, creating it lazily or waiting for returned capacity.

pub async fn acquire_cancellable( &self, active_policy: ActiveRequestPolicy, cancellation: &CancellationToken, ) -> Result<ClientLease<M>, AcquireError<M::Error>>

Acquire one client while also observing caller-owned cancellation.

pub async fn run(&self, cancellation: CancellationToken) -> Result<(), M::Error>

Maintain the declared warm floor until cancellation, then close and drain.

pub fn close(&self)

Reject new acquisitions and drop retained idle clients.

pub async fn drain(&self)

Stop admission and wait indefinitely for every leased or creating client to end.

pub fn pause(&self, reason: impl Into<Arc<str>>)

Pause new acquisitions without retiring retained or leased clients.

pub fn resume(&self) -> bool

Resume a policy-paused pool. Closing and draining are irreversible.

pub fn apply(&self, directive: PoolDirective)

Apply a protocol-neutral admission consequence.

pub fn cancel_active(&self) -> bool

Explicitly cancel work holding a lease after admission has stopped.

Graceful Self::drain never calls this. The runtime may call it only when its own policy has decided that active requests should no longer be preserved. Calling it while admission is open has no effect.

pub fn stats(&self) -> PoolStats

Trait Implementations

impl<M: ClientManager> Clone for ClientPool<M>

fn clone(&self) -> Self

Returns a duplicate of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.