Struct ConnPool 

pub struct ConnPool<T> {
    pub http: Arc<ConnPoolTable<T>>,
    pub https: Arc<ConnPoolTable<T>>,
    pub tasks: Arc<Mutex<JoinSet<()>>>,
}

Manages separate pools for HTTP and HTTPS connections, allowing for efficient connection reuse based on the target authority.

The connection pool maintains separate tables for HTTP and HTTPS connections, indexed by authority (host:port). Each entry contains a queue of pooled connections that can be reused for subsequent requests to the same authority.

Fields

http: Arc<ConnPoolTable<T>>

Pool of HTTP connections indexed by authority

https: Arc<ConnPoolTable<T>>

Pool of HTTPS connections indexed by authority

tasks: Arc<Mutex<JoinSet<()>>>

Background tasks for connection management

Implementations

impl<T> ConnPool<T>

pub async fn evict(&self, timeout: Duration)

Evicts connections from both HTTP and HTTPS pools that have been idle for longer than the specified timeout.

Arguments

• timeout - Duration after which connections are considered idle

pub async fn connect_http( &self, authority: &str, ) -> Result<Cacheable<PooledConn<SendRequest<T>>>, ErrorCode>

where T: Body + Send + 'static, T::Data: Send, T::Error: Into<Box<dyn Error + Send + Sync>>,

Attempts to get an HTTP connection for the specified authority. If a cached connection is available, it will be returned as a Hit. Otherwise, a new connection will be established and returned as a Miss.

Arguments

• authority - The authority (host:port) to connect to

Returns

A cacheable connection or an error if the connection fails

pub async fn connect_https( &self, tls: &TlsConnector, authority: &str, ) -> Result<Cacheable<PooledConn<SendRequest<T>>>, ErrorCode>

where T: Body + Send + 'static, T::Data: Send, T::Error: Into<Box<dyn Error + Send + Sync>>,

Attempts to get an HTTPS connection for the specified authority. If a cached connection is available, it will be returned as a Hit. Otherwise, a new connection will be established and returned as a Miss.

Arguments

• tls - The TLS connector to use for establishing secure connections
• authority - The authority (host:port) to connect to

Returns

A cacheable connection or an error if the connection fails

Trait Implementations

impl<T> Clone for ConnPool<T>

fn clone(&self) -> Self

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl<T: Debug> Debug for ConnPool<T>

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

Formats the value using the given formatter.

impl<T> Default for ConnPool<T>

Default implementation for the connection pool, creating a new instance with empty HTTP and HTTPS pools and a join set for managing tasks.

fn default() -> Self

Returns the “default value” for a type.