Struct ChannelManager 

pub struct ChannelManager { /* private fields */ }

High-performance channel manager for WebSocket channel operations

Implementations

impl ChannelManager

pub fn new() -> Self

Create a new channel manager

pub async fn create_channel( &self, name: String, channel_type: ChannelType, created_by: Option<ConnectionId>, ) -> WebSocketResult<ChannelId>

Create a new channel

pub async fn create_channel_with_metadata( &self, metadata: ChannelMetadata, ) -> WebSocketResult<ChannelId>

Create a channel with custom metadata

pub async fn delete_channel(&self, channel_id: ChannelId) -> WebSocketResult<()>

Delete a channel

pub async fn get_channel(&self, channel_id: ChannelId) -> Option<Arc<Channel>>

Get a channel by ID

pub async fn get_channel_by_name(&self, name: &str) -> Option<Arc<Channel>>

Get a channel by name

pub async fn get_all_channels(&self) -> Vec<Arc<Channel>>

Get all channels

pub async fn get_connection_channels( &self, connection_id: ConnectionId, ) -> Vec<Arc<Channel>>

Get channels that a connection is a member of

pub async fn join_channel( &self, channel_id: ChannelId, connection_id: ConnectionId, password: Option<&str>, nickname: Option<String>, ) -> WebSocketResult<()>

Join a connection to a channel

pub async fn leave_channel( &self, channel_id: ChannelId, connection_id: ConnectionId, ) -> WebSocketResult<()>

Remove a connection from a channel

pub async fn leave_all_channels( &self, connection_id: ConnectionId, ) -> Vec<ChannelId>

Remove a connection from all channels (useful for cleanup on disconnect)

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

Send a message to a channel

pub async fn get_all_channel_stats(&self) -> Vec<ChannelStats>

Get channel statistics for all channels

pub async fn get_public_channels(&self) -> Vec<ChannelStats>

Get public channels for discovery

pub async fn stats(&self) -> ChannelManagerStats

Get manager statistics

pub async fn cleanup_empty_channels(&self) -> usize

Clean up empty channels

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

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

Add an event handler

Trait Implementations

impl Default for ChannelManager

fn default() -> Self

Returns the “default value” for a type.