Struct ConnectionManager 

pub struct ConnectionManager { /* private fields */ }

Connection manager service

Implementations

impl ConnectionManager

pub fn new(timeout_duration: Duration, max_connections: usize) -> Self

pub async fn register_connection( &self, session_id: SessionId, ) -> Result<(), DomainError>

Register a new connection

pub async fn update_activity( &self, session_id: &SessionId, ) -> Result<(), DomainError>

Update connection activity

pub async fn update_metrics( &self, session_id: &SessionId, bytes_sent: usize, bytes_received: usize, ) -> Result<(), DomainError>

Update connection metrics

pub async fn set_stream( &self, session_id: &SessionId, stream_id: StreamId, ) -> Result<(), DomainError>

Associate stream with connection

pub async fn close_connection( &self, session_id: &SessionId, ) -> Result<(), DomainError>

Close connection

pub async fn remove_connection( &self, session_id: &SessionId, ) -> Result<(), DomainError>

Remove connection completely

pub async fn get_connection( &self, session_id: &SessionId, ) -> Option<ConnectionState>

Get connection state

pub async fn get_active_connections(&self) -> Vec<ConnectionState>

Get all active connections

pub async fn check_timeouts(&self) -> Vec<SessionId>

Check for timed out connections

pub async fn process_timeouts(&self)

Process timeout check iteration (to be called by infrastructure layer)

pub async fn get_statistics(&self) -> ConnectionStatistics

Get connection statistics