Struct SessionManager 

pub struct SessionManager {
    sessions: Mutex<HashMap<SessionId, ManagedSession>>,
    next_id: Mutex<SessionId>,
    timeout: Duration,
}

Manages all active sessions.

Provides thread-safe access to create, retrieve, and remove sessions. Sessions persist for a configurable timeout after all clients disconnect.

Fields

sessions: Mutex<HashMap<SessionId, ManagedSession>>

Map of session IDs to managed sessions.

next_id: Mutex<SessionId>

Counter for generating unique session IDs.

timeout: Duration

Session timeout duration.

Implementations

impl SessionManager

pub fn create_session(&self) -> Arc<Session>

Create a new session and return a reference to it.

pub fn get_or_create_session( &self, session_id: Option<SessionId>, ) -> (Arc<Session>, bool)

Get an existing session by ID, or create a new one if the ID doesn’t exist.

If session_id is Some, attempts to retrieve that session. If the session doesn’t exist or session_id is None, creates a new session.

Returns the session and whether it was newly created.

pub fn get_session(&self, id: SessionId) -> Option<Arc<Session>>

Get a session by ID without incrementing the connection count.

pub fn client_disconnected(manager: Arc<Self>, id: SessionId)

Mark a session as disconnected by a client.

If no more clients are connected, starts the timeout countdown. The session will be removed after the timeout unless a client reconnects.

fn schedule_cleanup(manager: Arc<Self>, id: SessionId)

Schedule a cleanup check for a session after the timeout period.

pub fn cleanup_expired_sessions(&self)

Perform cleanup of expired sessions.

This should be called periodically or after timeout events.

pub fn remove_session(&self, id: SessionId) -> Option<Arc<Session>>

Remove a session immediately.

pub fn session_count(&self) -> usize

Get the number of active sessions.

pub fn session_ids(&self) -> Vec<SessionId>

Get all active session IDs.

pub fn get_sessions_info(&self) -> Vec<SessionInfo>

Get information about all active sessions.

Returns a vector of SessionInfo structs containing session state snapshots for use by session management tools.

pub fn start_cleanup_task(manager: Arc<Self>)

Start a background task that periodically cleans up expired sessions.

Trait Implementations

impl Default for SessionManager

fn default() -> Self

Returns the “default value” for a type.