Struct ConnectionManager 

pub struct ConnectionManager { /* private fields */ }

Manages tunnel connections with per-connection FSM and sequence tracking.

Implementations

impl ConnectionManager

pub fn new( max_connections: usize, heartbeat_timeout: Duration, individual_address_base: IndividualAddress, ) -> Self

Create a new connection manager.

pub fn with_desync_threshold(self, threshold: u8) -> Self

Create with custom fatal desync threshold.

pub fn allocate_channel(&self) -> Option<u8>

Allocate a new channel.

pub fn create_connection( &self, channel_id: u8, client_addr: SocketAddr, data_endpoint: SocketAddr, ) -> Arc<TunnelConnection>

Create a new connection with Phase 1 components.

pub fn get(&self, channel_id: u8) -> Option<Arc<TunnelConnection>>

Get a connection.

pub fn remove(&self, channel_id: u8) -> Option<Arc<TunnelConnection>>

Remove a connection.

pub fn all(&self) -> Vec<Arc<TunnelConnection>>

Get all connections.

pub fn len(&self) -> usize

Get connection count.

pub fn is_empty(&self) -> bool

Check if empty.

pub fn cleanup_timed_out(&self) -> Vec<u8>

Clean up timed out connections.