Struct SessionRegistry 

pub struct SessionRegistry { /* private fields */ }

Session registry:

• session_key -> Connection
• user_key -> {session_key...}
• tenant_id -> count (Atomic)

Implementations

impl SessionRegistry

pub fn new() -> SessionRegistry

pub fn try_insert( &self, tenant_id: String, user_key: String, session_key: String, conn: Connection, max_total: u64, ) -> Result<(), WsPrismError>

Insert a session while enforcing a tenant-wide cap (best-effort).

Concurrency note: For throughput, this uses lock-free atomics plus an optimistic increment/check pattern. Under extreme contention, a small temporary overshoot of max_total is possible before the counter is corrected. This is an intentional trade-off to avoid global locks.

pub fn remove_session( &self, user_key: &str, session_key: &str, ) -> Option<Connection>

pub fn get_session(&self, session_key: &str) -> Option<Connection>

pub fn get_user_sessions(&self, user_key: &str) -> Vec<Connection>

pub fn count_user_sessions(&self, user_key: &str) -> usize

pub fn count_tenant_sessions(&self, tenant_id: &str) -> u64

pub fn all_sessions(&self) -> Vec<(String, Connection)>

Snapshot of all active sessions.

Returns a vector of (session_key, Connection). Intended for best-effort shutdown/draining logic.

pub fn len_sessions(&self) -> usize

pub fn evict_oldest(&self, user_key: &str) -> Option<(String, Connection)>

Evict the oldest session for this user. Returns (victim_session_key, victim_connection).

Trait Implementations

impl Default for SessionRegistry

fn default() -> SessionRegistry

Returns the “default value” for a type.