Struct SessionManager 

pub struct SessionManager { /* private fields */ }

Global session manager for MCP servers

Implementations

impl SessionManager

pub fn new(default_capabilities: ServerCapabilities) -> Self

Create a new session manager with InMemory storage

pub fn with_timeouts( default_capabilities: ServerCapabilities, session_timeout: Duration, cleanup_interval: Duration, ) -> Self

Create a new session manager with custom timeouts and InMemory storage

pub fn with_storage( storage: Arc<BoxedSessionStorage>, default_capabilities: ServerCapabilities, ) -> Self

Create a new session manager with specific storage backend

pub fn with_storage_and_timeouts( storage: Arc<BoxedSessionStorage>, default_capabilities: ServerCapabilities, session_timeout: Duration, cleanup_interval: Duration, ) -> Self

Create a new session manager with custom storage and timeouts

pub async fn create_session(&self) -> String

Create a new session and return its ID

pub async fn create_session_with_id(&self, session_id: String) -> String

Create a new session with a specific ID (for testing only - see trait documentation)

pub async fn add_session_to_cache( &self, session_id: String, server_capabilities: ServerCapabilities, )

Add an externally created session to the cache Used when session_handler creates a session directly in storage

pub async fn load_session_from_storage( &self, session_id: &str, ) -> Result<bool, SessionError>

Load session from storage into cache with its actual capabilities This preserves the negotiated capabilities and session state from persistent storage

pub async fn touch_session(&self, session_id: &str) -> Result<(), SessionError>

Get session and update last accessed time

pub async fn initialize_session( &self, session_id: &str, client_info: Implementation, client_capabilities: ClientCapabilities, ) -> Result<(), SessionError>

Initialize a session with client information

pub async fn initialize_session_with_version( &self, session_id: &str, client_info: Implementation, client_capabilities: ClientCapabilities, mcp_version: McpVersion, ) -> Result<(), SessionError>

Initialize a session with client information and negotiated protocol version

pub async fn session_exists(&self, session_id: &str) -> bool

Check if session exists and is valid

pub async fn get_session_state( &self, session_id: &str, key: &str, ) -> Option<Value>

Get session state value

pub async fn set_session_state(&self, session_id: &str, key: &str, value: Value)

Set session state value

pub async fn remove_session_state( &self, session_id: &str, key: &str, ) -> Option<Value>

Remove session state value

pub async fn is_session_initialized(&self, session_id: &str) -> bool

Check if session is initialized

pub async fn remove_session(&self, session_id: &str) -> bool

Remove a session

pub async fn cleanup_expired(&self) -> usize

Cleanup expired sessions

pub async fn send_event_to_session( &self, session_id: &str, event: SessionEvent, ) -> Result<(), SessionError>

Send event to specific session

pub async fn broadcast_event(&self, event: SessionEvent)

Broadcast event to all sessions

pub async fn session_count(&self) -> usize

Get active session count

pub fn create_session_context( self: &Arc<Self>, session_id: &str, ) -> Option<SessionContext>

Create session context for a session

pub fn start_cleanup_task(self: Arc<Self>) -> JoinHandle<()>

Start automatic cleanup task

pub async fn get_session_event_receiver( &self, session_id: &str, ) -> Option<Receiver<SessionEvent>>

Get a session’s event receiver for SSE streaming

pub fn subscribe_all_session_events(&self) -> Receiver<(String, SessionEvent)>

Subscribe to events from all sessions Returns a receiver that gets (session_id, event) tuples for all session events

pub fn get_storage(&self) -> Arc<BoxedSessionStorage>

Get the storage backend for use by other components (e.g., HTTP server) This ensures all components use the same storage backend

pub fn get_default_capabilities(&self) -> ServerCapabilities

Get the default capabilities for use by other components

pub async fn session_exists_in_cache(&self, session_id: &str) -> bool

Check if session exists in the in-memory cache only (not storage)