Struct ConnectionManager 

pub struct ConnectionManager { /* private fields */ }

Thread-safe manager for active WebSocket connections.

Uses DashMap for lock-free concurrent reads and writes. Each connection has an event sender for delivering change events and a oneshot close-signal channel for graceful server-initiated disconnection (e.g., slow consumer policy).

Implementations

impl ConnectionManager

pub fn new( max_consecutive_drops: usize, connection_event_capacity: usize, ) -> Self

Create a new empty connection manager.

pub fn insert( &self, state: ConnectionState, ) -> (Receiver<String>, Receiver<CloseSignal>)

Register a new connection and return a receiver for events and a close-signal receiver.

The event receiver should be polled by the connection handler to forward change events to the WebSocket. The close-signal receiver fires when the delivery pipeline detects a slow consumer.

pub fn remove(&self, connection_id: &str)

Remove a connection by ID, cleaning up all associated state.

pub fn count(&self) -> usize

Total number of active connections.

pub fn count_by_context(&self, context_hash: u64) -> usize

Number of connections for a specific security context hash.

pub fn send_event(&self, connection_id: &str, json: String) -> bool

Send a serialized event to a connection’s event channel.

On success, resets the per-connection drop counter. On failure (channel full), increments the drop counter. If the counter reaches max_consecutive_drops, a close signal with code 4002 (“slow consumer”) is sent to the connection handler.

Returns true if the event was sent, false otherwise.

pub fn drop_count(&self, connection_id: &str) -> usize

Return the current consecutive drop count for a connection (for testing).

Trait Implementations

impl Default for ConnectionManager

fn default() -> Self

Returns the “default value” for a type.