Struct HttpPooledConnectorConfig 

pub struct HttpPooledConnectorConfig {
    pub max_total: usize,
    pub max_concurrent_streams: usize,
    pub selection: MuxSelection,
    pub idle_timeout: Option<Duration>,
    pub wait_for_pool_timeout: Option<Duration>,
}

Config used to create a multiplexing http connection pool (MultiplexPool).

The per-connection concurrency comes from the connection’s MaxConcurrency extension (set by the http connectors: 1 for http/1, the stream capacity for http/2), clamped to max_concurrent_streams as an upper bound.

Fields

max_total: usize

Set the max amount of connections that this connection pool will contain

This is the sum of active connections and idle connections. When this limit is hit idle connections will be replaced with new ones.

max_concurrent_streams: usize

Upper bound on the concurrent requests a single connection may serve.

Acts as a ceiling for each connection, each connection also figures it’s own max concurrency out by itself

selection: MuxSelection

How a connection is chosen among several that can serve a request.

idle_timeout: Option<Duration>

If connections have been idle (no active streams) for longer than this timeout they are dropped. Only checked when a connection is requested.

wait_for_pool_timeout: Option<Duration>

How long to wait for the pool to hand out a connection before timing out.

Implementations

impl HttpPooledConnectorConfig

pub fn build_default_connector<S>(inner: S) -> HttpPooledConnector<S>

where S: ConnectorService<ConnectRequest>,

Build a pooled HTTP connector using Rama’s known-valid default limits.

Unlike Self::try_build_connector, this constructor is infallible because its connection and concurrency limits are non-zero constants owned by Rama.

pub fn try_build_connector<S>( self, inner: S, ) -> Result<HttpPooledConnector<S>, BoxError>

where S: ConnectorService<ConnectRequest>,

Build a pooled HTTP connector around inner.

The connector only adds body binding and pool lookup. HTTP request adaptation and proxy-route selection remain independently composable services and can be layered around the returned connector when needed.

The returned connector wraps each pooled connection in BindBodyToConn, so the pool only frees/reuses a connection once its response body has been consumed, not at response headers.

Warning: the connection returned by this pool should only be used for a single request. Every request should go through the connector stack again, and will receive a new or reused connection (maybe multiplexed) of its own.

Trait Implementations

impl Clone for HttpPooledConnectorConfig

fn clone(&self) -> Self

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for HttpPooledConnectorConfig

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

Formats the value using the given formatter.

impl Default for HttpPooledConnectorConfig

fn default() -> Self

Returns the “default value” for a type.