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 mcp_session(&self) -> Arc<Session>

Returns the session shared by all MCP clients, creating it if there is none.

It’s never counted as connected. Instead, SessionManager::cleanup_expired_sessions removes it once no request has been sent through it for DEFAULT_SESSION_TIMEOUT_SECS, if it has no open packs and no unfinished jobs.

fn create_session_internal(&self, is_mcp: bool) -> Arc<Session>

fn insert_session( &self, sessions: &mut HashMap<SessionId, ManagedSession>, is_mcp: bool, ) -> Arc<Session>

Creates a session and adds it to the provided sessions, which must be the locked SessionManager::sessions.

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(&self, id: SessionId)

Mark a session as disconnected by a client.

If no more clients are connected, starts the timeout countdown. SessionManager::cleanup_expired_sessions removes the session after the timeout unless a client reconnects.

pub fn cleanup_expired_sessions(&self) -> bool

Perform cleanup of expired sessions.

This should be called periodically.

Returns

If a WebSocket session was removed.

pub fn exit_if_no_sessions(&self)

Stops the server process if there are no sessions left.

Called after a WebSocket session is removed. Removing the MCP session never stops the process, so a server only used by MCP clients keeps running.

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, and stops the server when none are left.

Trait Implementations

impl Default for SessionManager

fn default() -> Self

Returns the “default value” for a type.