Struct ConnectionPool 

pub struct ConnectionPool { /* private fields */ }

Thread-safe connection pool shared across concurrent forward_request tasks. Cloneable — internal state lives behind an Arc<Mutex<...>> so cloning is cheap (bumps the ref-count).

Implementations

impl ConnectionPool

pub fn new() -> Self

pub async fn get_h2(&self, host: &str, port: u16) -> Option<PooledH2Sender>

Try to reuse an HTTP/2 sender for (host, port). Returns None if we have no cached entry OR the cached entry has gone idle beyond IDLE_TIMEOUT. Fresh senders returned from here can be used immediately — SendRequest clones share the same underlying connection driver task.

pub async fn store_h2(&self, host: &str, port: u16, sender: PooledH2Sender)

Cache a freshly-negotiated HTTP/2 sender so future requests to the same host reuse the underlying TCP+TLS+h2 session.

pub async fn invalidate_h2(&self, host: &str, port: u16)

Remove the cached h2 sender for a host — call this when a request against a cached sender fails, so the next attempt re-handshakes.

Trait Implementations

impl Clone for ConnectionPool

fn clone(&self) -> ConnectionPool

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for ConnectionPool

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

Formats the value using the given formatter.

impl Default for ConnectionPool

fn default() -> ConnectionPool

Returns the “default value” for a type.