Struct ConnectionPool 

pub struct ConnectionPool { /* private fields */ }

Connection pool for managing active connections

Implementations

impl ConnectionPool

pub fn new(max_connections: Option<usize>) -> Self

Create a pool bounded to max_connections, or unbounded on None.

pub fn try_reserve(&self) -> bool

Reserve one connection slot ahead of an accept.

Returns false when the pool (active plus reserved) is at capacity.

pub fn cancel_reservation(&self)

Release a slot taken by Self::try_reserve without admitting a connection.

pub fn add_connection(&self, addr: SocketAddr) -> ConnectionId

Register a connection and return its unique id. The id is what the owning stream stores and later passes to Self::remove_connection.

pub fn add_connection_reserved(&self, addr: SocketAddr) -> ConnectionId

Convert a successful reservation into a tracked connection, returning the new connection id. Releases exactly the one reservation taken by Self::try_reserve.

pub fn record_io(&self, id: ConnectionId, bytes_received: u64, bytes_sent: u64)

Record I/O activity on a tracked connection, updating its byte counters and last_activity timestamp. No-op when the connection is no longer tracked (already removed or never pool-tracked).

pub fn remove_connection(&self, id: ConnectionId) -> bool

Remove a tracked connection; returns whether it was present.

pub fn has_capacity(&self) -> bool

Return whether the pool can admit another connection.

pub fn get_active_connections(&self) -> HashMap<ConnectionId, ConnectionInfo>

Snapshot the tracked connections.

pub fn connection_count(&self) -> usize

Count of connections currently tracked as open.

Trait Implementations

impl Debug for ConnectionPool

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

Formats the value using the given formatter.