Struct SessionManager

pub struct SessionManager { /* private fields */ }

Manages multiple concurrent sessions

Implementations

impl SessionManager

pub fn new(store: Arc<dyn SessionStore>, config: SessionManagerConfig) -> Self

Create a new SessionManager

pub async fn create_session( &self, config: SessionConfig, app_config: AppConfig, ) -> Result<(String, Sender<AppCommand>)>

Create a new session

pub async fn take_event_receiver( &self, session_id: &str, ) -> Result<Receiver<AppEvent>>

Take the event receiver for a session (can only be called once per session)

pub async fn get_session(&self, session_id: &str) -> Result<Option<SessionInfo>>

Get session information

pub async fn get_session_workspace( &self, session_id: &str, ) -> Result<Option<Arc<dyn Workspace>>>

Get the workspace for a session

pub async fn resume_session( &self, session_id: &str, app_config: AppConfig, ) -> Result<Sender<AppCommand>>

Resume a session (load from storage and activate)

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

Suspend a session (save to storage and deactivate)

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

Delete a session permanently

pub async fn list_sessions( &self, filter: SessionFilter, ) -> Result<Vec<SessionInfo>>

List sessions with filtering

pub async fn get_active_sessions(&self) -> Vec<String>

Get active session IDs

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

Check if a session is active

pub async fn send_command( &self, session_id: &str, command: AppCommand, ) -> Result<()>

Send a command to an active session

pub async fn update_session_state( &self, session_id: &str, update_fn: impl FnOnce(&mut SessionState), ) -> Result<()>

Update session state and persist if auto-persist is enabled

pub async fn emit_event(&self, session_id: String, event: StreamEvent)

Emit an event for a session

pub async fn cleanup_inactive_sessions(&self, max_idle_time: Duration) -> usize

Cleanup inactive sessions

pub fn store(&self) -> &Arc<dyn SessionStore>

Get session store reference

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

Increment the subscriber count for a session

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

Decrement the subscriber count for a session

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

Touch a session to update its last activity timestamp

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

Check if a session should be suspended due to no subscribers

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

Get session state for gRPC responses

pub async fn get_mcp_statuses( &self, session_id: &str, ) -> Result<Vec<McpServerInfo>>

Get MCP server connection statuses for a session