Struct ConnectionManager 

pub struct ConnectionManager { /* private fields */ }

TCP connection management

Implementations

impl Manager

pub fn new(config: ConnectionConfig, stats_tx: Sender<StatEvent>) -> Self

pub async fn accept_connection( self: &Arc<Self>, addr: SocketAddr, ) -> Result<ConnectionGuard, RelayError>

Attempt to establish a new connection

pub async fn get_connection_count(&self, addr: &SocketAddr) -> usize

pub async fn get_total_connections(&self) -> usize

pub async fn record_request( &self, addr: SocketAddr, success: bool, duration: Duration, )

Updates statistics for a given request

pub async fn get_stats(&self) -> Result<ConnectionStats, RelayError>

Gets complete connection statistics

pub fn stats_tx(&self) -> Sender<StatEvent>

Trait Implementations

impl Debug for Manager

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

Formats the value using the given formatter.