Struct ChannelRegistry 

pub struct ChannelRegistry { /* private fields */ }

Manages WebSocket channels/rooms with typed messages.

use framework::channel::ChannelRegistry;
use framework::http::ws::websocket_handler_with_state;

let channels = ChannelRegistry::new();

// Mount in router (uses the existing ws helper)
Router::new()
    .route("/ws/channels", get(|ws: WebSocketUpgrade, State(ch): State<ChannelRegistry>| {
        websocket_handler_with_state(ws, ch, |socket, ch| ch.handle_socket(socket))
    }));

// Broadcast from anywhere (controller, job, event handler)
channels.broadcast("chat/room-1", "new_message", &msg).await;

Implementations

impl ChannelRegistry

pub fn new() -> Self

pub async fn broadcast<T: Serialize>( &self, channel: &str, event: &str, data: &T, )

Broadcast a typed message to all clients subscribed to a channel

pub async fn broadcast_raw(&self, channel: &str, event: &str, payload: Value)

Broadcast a raw JSON value to a channel

pub async fn client_count(&self, channel: &str) -> usize

Get the number of connected clients in a channel

pub async fn active_channels(&self) -> Vec<String>

Get all active channel names

pub async fn handle_socket(self, socket: WebSocket)

Handle a WebSocket connection with the channel protocol.

The client sends JSON messages:

• Join: {"channel": "chat/room-1", "event": "join", "payload": {}}
• Leave: {"channel": "chat/room-1", "event": "leave", "payload": {}}
• Message: {"channel": "chat/room-1", "event": "message", "payload": {"text": "hello"}}

Trait Implementations

impl Clone for ChannelRegistry

fn clone(&self) -> ChannelRegistry

Returns a duplicate of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.

impl Default for ChannelRegistry

fn default() -> Self

Returns the “default value” for a type.