Struct PoolConfig 

pub struct PoolConfig {
    pub max_in_flight: Option<usize>,
    pub governor_acquire_timeout: Duration,
    pub max_connections_per_provider: usize,
    pub min_idle_connections: usize,
    pub idle_timeout: Duration,
    pub max_lifetime: Duration,
    pub health_check_interval: Duration,
    pub acquire_timeout: Duration,
    pub enable_health_check: bool,
}

Configuration for the client pool

Fields

max_in_flight: Option<usize>

Maximum number of in-flight dispatches admitted per provider.

None (default) keeps admission unlimited — governed wrappers are never installed and behavior is unchanged. See ProviderGovernor for the WHO-vs-HOW-MUCH throttle split: this caps how much load one backend absorbs; tenant-level quotas decide who may call at all.

governor_acquire_timeout: Duration

Maximum time a dispatch waits for an in-flight slot before failing closed (only relevant when max_in_flight is set).

max_connections_per_provider: usize

Maximum number of clients per provider (default: 10)

min_idle_connections: usize

Minimum number of idle clients to maintain per provider (default: 2)

idle_timeout: Duration

Maximum time a client can be idle before being considered stale (default: 5 minutes)

max_lifetime: Duration

Maximum lifetime of a client before forced refresh (default: 30 minutes)

health_check_interval: Duration

How often to run health checks on idle connections (default: 60 seconds)

acquire_timeout: Duration

Timeout for acquiring a client from the pool (default: 30 seconds)

enable_health_check: bool

Whether to enable connection health checking (default: true)

Implementations

impl PoolConfig

pub fn with_max_connections(self, max: usize) -> Self

Create a new pool config with custom max connections

pub fn with_max_in_flight(self, max: usize) -> Self

Enable a per-provider in-flight cap of max concurrent dispatches.

Admission happens at the wrap funnel ([ProviderPool::acquire] and [ProviderPool::try_acquire]) so every checkout path — pooled or freshly created clients alike — is governed identically. The permit spans the whole call, streams included.

pub fn with_governor_acquire_timeout(self, timeout: Duration) -> Self

Set the wait budget for acquiring an in-flight slot.

pub fn governor_config(&self) -> GovernorConfig

Effective governor configuration for this pool.

pub fn with_idle_timeout(self, timeout: Duration) -> Self

Create a new pool config with custom idle timeout

pub fn with_max_lifetime(self, lifetime: Duration) -> Self

Create a new pool config with custom max lifetime

pub fn without_health_check(self) -> Self

Disable health checking (useful for testing)

Trait Implementations

impl Clone for PoolConfig

fn clone(&self) -> PoolConfig

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for PoolConfig

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.

impl Default for PoolConfig

fn default() -> Self

Returns the “default value” for a type.

impl<'de> Deserialize<'de> for PoolConfig

fn deserialize<__D>(__deserializer: __D) -> Result<Self, __D::Error>

where __D: Deserializer<'de>,

Deserialize this value from the given Serde deserializer.

impl Display for PoolConfig

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.

impl PartialEq for PoolConfig

fn eq(&self, other: &PoolConfig) -> bool

Equality operator ==.

fn ne(&self, other: &Rhs) -> bool

Inequality operator !=.

impl Serialize for PoolConfig

fn serialize<__S>(&self, __serializer: __S) -> Result<__S::Ok, __S::Error>

where __S: Serializer,

Serialize this value into the given Serde serializer.

impl StructuralPartialEq for PoolConfig