Struct ConnectionManager 

pub struct ConnectionManager { /* private fields */ }

Connection manager

Implementations

impl ConnectionManager

pub fn new(max_connections: usize) -> Self

Create a new connection manager

pub fn add(&self, connection: Arc<Connection>) -> Result<()>

Add a connection

pub fn remove(&self, id: &ConnectionId) -> Option<Arc<Connection>>

Remove a connection

pub fn get(&self, id: &ConnectionId) -> Option<Arc<Connection>>

Get a connection by ID

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

Get all connections

pub fn count(&self) -> usize

Get connection count

pub fn total_connections(&self) -> u64

Get total connections served

pub async fn broadcast(&self, message: Message) -> Result<usize>

Broadcast a message to all connections

pub async fn broadcast_to( &self, ids: &[ConnectionId], message: Message, ) -> Result<usize>

Broadcast a message to specific connections

pub async fn broadcast_filtered<F>( &self, message: Message, filter: F, ) -> Result<usize>

where F: Fn(&Arc<Connection>) -> bool,

Broadcast to connections matching a filter

pub async fn close_all(&self) -> Result<()>

Close all connections

pub async fn close_idle(&self, timeout_secs: u64) -> Result<usize>

Close idle connections

pub async fn get_by_room(&self, room: &str) -> Vec<Arc<Connection>>

Get connections by room

pub async fn get_by_topic(&self, topic: &str) -> Vec<Arc<Connection>>

Get connections by topic

pub fn subscribe(&self) -> Receiver<ConnectionEvent>

Subscribe to connection events

pub fn stats(&self) -> ConnectionManagerStats

Get manager statistics