Struct ConnectionPool 

pub struct ConnectionPool { /* private fields */ }

Connection pool for managing reusable TCP connections

Implementations

impl ConnectionPool

pub fn new() -> Self

Create a new connection pool

pub fn with_idle_timeout(timeout: Duration) -> Self

Create a new connection pool with custom idle timeout

pub async fn get_or_create(&self, target_addr: &str) -> Result<TcpStream, Error>

Get a connection from the pool or create a new one

pub async fn get(&self, target_addr: &str) -> Option<TcpStream>

Get a connection from the pool if available

pub async fn put(&self, target_addr: String, stream: TcpStream)

Return a connection to the pool

pub async fn clear(&self)

Clear all connections from the pool

pub async fn len(&self) -> usize

Get the number of connections in the pool

pub async fn is_empty(&self) -> bool

Check if the pool is empty

Trait Implementations

impl Debug for ConnectionPool

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

Formats the value using the given formatter.

impl Default for ConnectionPool

fn default() -> Self

Returns the “default value” for a type.