Struct ConnectionRegistry 

pub struct ConnectionRegistry { /* private fields */ }

Sharded, lock-free-on-the-hot-path connection registry.

One instance is created at launch, leaked to &'static, and shared by every gateway route. All mutating operations are O(1) amortised and touch only a single shard; broadcast is O(connections) with no global lock.

Implementations

impl ConnectionRegistry

pub fn new() -> Self

pub fn register( &self, tx: UnboundedSender<WsMessage>, claims: Option<Arc<Claims>>, ) -> ConnId

Register a freshly-upgraded socket. Returns its assigned ConnId.

pub fn unregister(&self, id: ConnId)

Remove a socket and evict it from every room it had joined.

pub fn connection_count(&self) -> usize

Number of live connections. O(1).

pub fn join_room(&self, id: ConnId, room: String)

Add a connection to a room (Socket.IO-style logical channel).

TOCTOU safety

Both member_rooms and rooms are updated while holding the DashMap shard read-lock on conns (the Ref keeps the shard locked until it is dropped). This prevents a concurrent unregister() — which needs the shard write-lock — from removing the entry between the two writes, which would otherwise leave a stale ConnId in rooms forever.

pub fn leave_room(&self, id: ConnId, room: &str)

Remove a connection from a room.

Mirrors join_room’s lock order: hold the conns shard read-lock first so a concurrent unregister() (which needs the write-lock) cannot remove the entry between the two writes and leave a stale id in rooms.

pub fn send_text(&self, id: ConnId, text: Arc<str>)

Enqueue a text frame to one connection. Non-blocking; a dead receiver is silently dropped (the reader loop will unregister it shortly).

pub fn broadcast_text(&self, text: &str)

Fan a text frame out to every live connection. Creates one Arc<str> allocation then enqueues N pointer copies — no per-connection memcpy.

pub fn broadcast_room_text(&self, room: &str, text: &str)

Fan a text frame out to the members of one room.

Trait Implementations

impl Default for ConnectionRegistry

fn default() -> Self

Returns the “default value” for a type.