Struct ConnectionManager 

pub struct ConnectionManager { /* private fields */ }

Connection manager

Implementations

impl ConnectionManager

pub fn new(config: ServerConfig) -> Self

Create a new connection manager

pub fn set_cleanup_interval(&mut self, interval: Duration)

Set the cleanup interval

pub async fn add_connection(&self, connection: Connection) -> u64

Add a new connection and return its assigned ID.

pub async fn remove_connection(&self, id: u64, reason: CloseReason)

Remove a connection

pub async fn get_connection(&self, id: u64) -> Option<ConnectionHandle>

Get connection by ID

pub async fn get_all_connections(&self) -> Vec<ConnectionHandle>

Get all active connections

pub async fn connection_count(&self) -> usize

Get current connection count

pub async fn get_stats(&self) -> ManagerStats

Get connection manager statistics

pub async fn start_cleanup_task(&self)

Start the cleanup task

pub async fn monitor_connections(&self) -> Result<Vec<ConnectionHealth>>

Monitor connection health

pub async fn close_all_connections(&self)

Close all connections

pub async fn broadcast_binary_to_all(&self, data: &[u8]) -> Result<()>

Broadcast binary to every active connection.

pub async fn broadcast_text_to_all(&self, text: &str) -> Result<()>

Broadcast text to every active connection.

pub async fn broadcast_binary_except( &self, data: &[u8], except_id: u64, ) -> Result<()>

Broadcast binary to all connections except the one with except_id.

pub async fn broadcast_text_except( &self, text: &str, except_id: u64, ) -> Result<()>

Broadcast text to all connections except the one with except_id.

Trait Implementations

impl Debug for ConnectionManager

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

Formats the value using the given formatter.

impl Drop for ConnectionManager

fn drop(&mut self)

Executes the destructor for this type.