Struct WebSocketState 

pub struct WebSocketState {
    pub broadcast_tx: Sender<WsServerMessage>,
    pub channel_senders: RwLock<HashMap<String, Sender<WsServerMessage>>>,
    pub clients: RwLock<HashMap<String, ClientInfo>>,
    pub version: AtomicU64,
}

Global WebSocket state shared across connections

Fields

broadcast_tx: Sender<WsServerMessage>

Broadcast channel for server-wide messages

channel_senders: RwLock<HashMap<String, Sender<WsServerMessage>>>

Per-channel broadcast senders

clients: RwLock<HashMap<String, ClientInfo>>

Connected clients info

version: AtomicU64

Current sync version

Implementations

impl WebSocketState

pub fn new() -> Self

pub fn get_channel_sender(&self, channel: &str) -> Sender<WsServerMessage>

Get or create a channel sender

pub fn broadcast(&self, msg: WsServerMessage)

Broadcast to all clients

pub fn broadcast_to_channel(&self, channel: &str, msg: WsServerMessage)

Broadcast to a specific channel

pub fn increment_version(&self) -> u64

Increment version and return new value

pub fn current_version(&self) -> u64

Get current version

pub fn register_client(&self, id: &str)

Register a new client

pub fn unregister_client(&self, id: &str)

Unregister a client

pub fn client_count(&self) -> usize

Get client count

Trait Implementations

impl Default for WebSocketState

fn default() -> Self

Returns the “default value” for a type.