Struct ConnectionRegistry 

pub struct ConnectionRegistry { /* private fields */ }

High-performance connection registry using Arc<RwLock<>> for concurrent access

Implementations

impl ConnectionRegistry

pub fn new() -> Self

Create a new connection registry

pub fn with_channel_manager(channel_manager: Arc<ChannelManager>) -> Self

Create a new connection registry with existing channel manager

pub fn channel_manager(&self) -> &Arc<ChannelManager>

Get the channel manager

pub async fn add_connection( &self, connection: WebSocketConnection, ) -> ConnectionId

Add a connection to the registry

pub async fn remove_connection( &self, id: ConnectionId, ) -> Option<Arc<WebSocketConnection>>

Remove a connection from the registry

pub async fn get_connection( &self, id: ConnectionId, ) -> Option<Arc<WebSocketConnection>>

Get a connection by ID

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

Get all active connections

pub async fn get_connection_ids(&self) -> Vec<ConnectionId>

Get all connection IDs

pub async fn connection_count(&self) -> usize

Get the number of active connections

pub async fn send_to_connection( &self, id: ConnectionId, message: WebSocketMessage, ) -> WebSocketResult<()>

Send a message to a specific connection

pub async fn send_text_to_connection<T: Into<String>>( &self, id: ConnectionId, text: T, ) -> WebSocketResult<()>

Send a text message to a specific connection

pub async fn send_binary_to_connection<T: Into<Vec<u8>>>( &self, id: ConnectionId, data: T, ) -> WebSocketResult<()>

Send a binary message to a specific connection

pub async fn broadcast(&self, message: WebSocketMessage) -> BroadcastResult

Broadcast a message to all active connections

pub async fn broadcast_text<T: Into<String>>(&self, text: T) -> BroadcastResult

Broadcast a text message to all active connections

pub async fn broadcast_binary<T: Into<Vec<u8>>>( &self, data: T, ) -> BroadcastResult

Broadcast a binary message to all active connections

pub async fn send_to_channel( &self, channel_id: ChannelId, sender_id: ConnectionId, message: WebSocketMessage, ) -> WebSocketResult<BroadcastResult>

Send a message to a specific channel

pub async fn send_text_to_channel<T: Into<String>>( &self, channel_id: ChannelId, sender_id: ConnectionId, text: T, ) -> WebSocketResult<BroadcastResult>

Send a text message to a specific channel

pub async fn send_binary_to_channel<T: Into<Vec<u8>>>( &self, channel_id: ChannelId, sender_id: ConnectionId, data: T, ) -> WebSocketResult<BroadcastResult>

Send a binary message to a specific channel

pub async fn close_connection(&self, id: ConnectionId) -> WebSocketResult<()>

Close a specific connection

pub async fn close_all_connections(&self) -> CloseAllResult

Close all connections

pub async fn cleanup_inactive_connections(&self) -> usize

Clean up inactive connections

pub async fn stats(&self) -> RegistryStats

Get registry statistics

pub async fn add_event_handler<F>(&self, handler: F)

where F: Fn(ConnectionEvent) + Send + Sync + 'static,

Add an event handler (for future extensibility)

Trait Implementations

impl Default for ConnectionRegistry

fn default() -> Self

Returns the “default value” for a type.