Struct AgentPoolConfig 

pub struct AgentPoolConfig {

    pub connections_per_agent: usize,
    pub load_balance_strategy: LoadBalanceStrategy,
    pub connect_timeout: Duration,
    pub request_timeout: Duration,
    pub reconnect_interval: Duration,
    pub max_reconnect_attempts: usize,
    pub drain_timeout: Duration,
    pub max_concurrent_per_connection: usize,
    pub health_check_interval: Duration,
    pub channel_buffer_size: usize,
    pub flow_control_mode: FlowControlMode,
    pub flow_control_wait_timeout: Duration,
    pub sticky_session_timeout: Option<Duration>,
}

Configuration for the agent connection pool.

Fields

connections_per_agent: usize

Number of connections to maintain per agent

load_balance_strategy: LoadBalanceStrategy

Load balancing strategy

connect_timeout: Duration

Connection timeout

request_timeout: Duration

Request timeout

reconnect_interval: Duration

Time between reconnection attempts

max_reconnect_attempts: usize

Maximum reconnection attempts before marking agent unhealthy

drain_timeout: Duration

Time to wait for in-flight requests during shutdown

max_concurrent_per_connection: usize

Maximum concurrent requests per connection

health_check_interval: Duration

Health check interval

channel_buffer_size: usize

Channel buffer size for all transports.

Controls backpressure behavior. Smaller values (16-64) apply backpressure earlier, preventing memory buildup. Larger values (128-256) handle burst traffic better but use more memory.

Default: 64

flow_control_mode: FlowControlMode

Flow control behavior when an agent signals it cannot accept requests.

Default: FlowControlMode::FailClosed

flow_control_wait_timeout: Duration

Timeout for FlowControlMode::WaitAndRetry before failing.

Only used when flow_control_mode is WaitAndRetry. Default: 100ms

sticky_session_timeout: Option<Duration>

Timeout for sticky sessions before they expire.

Sticky sessions are used for long-lived streaming connections (WebSocket, SSE, long-polling) to ensure the same agent connection is used for the entire stream lifetime.

Set to None to disable automatic expiry (sessions only cleared explicitly).

Default: 5 minutes

Trait Implementations

impl Clone for AgentPoolConfig

fn clone(&self) -> AgentPoolConfig

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for AgentPoolConfig

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

Formats the value using the given formatter.

impl Default for AgentPoolConfig

fn default() -> Self

Returns the “default value” for a type.