Struct ConnectionPool 

pub struct ConnectionPool { /* private fields */ }

Connection pool for reusing HTTP/1.1, HTTP/2, and HTTP/3 connections

Implementations

impl ConnectionPool

pub fn new() -> Self

Create a new connection pool with default settings

pub fn with_config( max_idle: Duration, max_per_host: usize, max_streams: u32, ) -> Self

Create a connection pool with custom configuration

pub async fn get_h1(&self, key: &PoolKey) -> Option<MaybeHttpsStream>

Get an idle HTTP/1.1 connection from the pool

pub async fn put_h1(&self, key: PoolKey, stream: MaybeHttpsStream)

Return an HTTP/1.1 connection to the pool

pub fn try_put_h1(&self, key: PoolKey, stream: MaybeHttpsStream) -> bool

Try to return an HTTP/1.1 connection to the pool without awaiting.

This is used by poll-based response bodies, where parking the caller on an async pool lock would couple body EOF to an unrelated task wake. If the pool lock is temporarily unavailable, the connection is safely discarded instead of being returned late or through a spawned shim.

pub async fn get_or_create( &self, key: &PoolKey, version: HttpVersion, ) -> Result<Option<PoolEntry>>

Get an existing connection or signal that a new one should be created

Returns:

• Ok(Some(entry)): Reusable connection found (HTTP/2 or HTTP/3)
• Ok(None): No reusable connection, create new one

pub async fn release(&self, key: &PoolKey)

Release a stream slot back to the pool

pub async fn invalidate(&self, key: &PoolKey)

Invalidate a connection (due to error, GOAWAY, etc.)

pub async fn cleanup(&self)

Remove expired and invalid connections

pub fn spawn_cleanup_task(self: Arc<Self>, interval: Duration) -> JoinHandle<()>

Spawn a background cleanup task that runs periodically

Returns a handle to the spawned task

pub async fn stats(&self) -> PoolStats

Get current pool statistics (for debugging/monitoring)

Trait Implementations

impl Default for ConnectionPool

fn default() -> Self

Returns the “default value” for a type.