Struct SessionManager 

pub struct SessionManager { /* private fields */ }

Manages multiple REPL sessions

Thread-safe session storage using Arc<RwLock>. Each session has its own EvalContext with isolated state.

Implementations

impl SessionManager

pub fn new() -> Self

Create a new session manager

pub fn create( &self, session_id: SessionId, mode: ReplMode, ) -> Result<SessionId, SessionError>

Create a new session

Errors

Returns SessionError::AlreadyExists if a session with the same ID already exists.

Example

use oxur_repl::server::SessionManager;
use oxur_repl::protocol::{ReplMode, SessionId};

let manager = SessionManager::new();
let session_id = manager.create(SessionId::new("session-1"), ReplMode::Lisp).unwrap();
assert_eq!(session_id, SessionId::new("session-1"));

pub fn create_with_compilation( &self, session_id: SessionId, mode: ReplMode, ) -> Result<SessionId, SessionError>

Create a new session with full compilation support

This creates a session with the full compilation pipeline including session directory, artifact cache, and subprocess executor.

Errors

Returns SessionError::AlreadyExists if a session with the same ID already exists. Returns SessionError::EvalFailed if the compilation pipeline cannot be initialized.

pub async fn eval( &self, session_id: &SessionId, code: impl AsRef<str>, ) -> Result<EvalResult, SessionError>

Execute an async operation with a session

Takes ownership of the evaluation, executes it, and updates the session. This avoids lifetime issues with async closures.

Errors

Returns SessionError::NotFound if the session doesn’t exist. Returns SessionError::EvalFailed if evaluation fails due to:

• Syntax errors in the code
• Type errors during compilation
• Runtime errors during execution
• Compilation errors
• Unsupported operations for the current tier

Returns SessionError::LockPoisoned if the internal lock is poisoned.

pub fn clone_session( &self, source_id: &SessionId, target_id: SessionId, ) -> Result<SessionId, SessionError>

Clone an existing session

Creates a new session with the same cache and state as the source session, but with a different session ID and reset statistics.

Errors

Returns SessionError::NotFound if the source session doesn’t exist. Returns SessionError::AlreadyExists if the target session ID is already in use.

pub fn close(&self, session_id: &SessionId) -> Result<(), SessionError>

Close a session

Removes the session and frees its resources.

Errors

Returns SessionError::NotFound if the session doesn’t exist.

pub fn list(&self) -> Result<Vec<SessionInfo>, SessionError>

List all active sessions

Returns information about all currently active sessions.

Errors

Returns SessionError::LockPoisoned if the internal lock is poisoned.

pub fn get_info( &self, session_id: &SessionId, ) -> Result<SessionInfo, SessionError>

Get information about a specific session

Errors

Returns SessionError::NotFound if the session doesn’t exist.

pub fn get_stats_collector( &self, session_id: &SessionId, ) -> Result<Arc<Mutex<EvalMetrics>>, SessionError>

Get the statistics collector for a session

Returns a shared reference to the session’s StatsCollector for detailed metrics access.

Errors

Returns SessionError::NotFound if the session doesn’t exist. Returns SessionError::LockPoisoned if the internal lock is poisoned.

pub fn get_usage_metrics( &self, session_id: &SessionId, ) -> Result<Arc<Mutex<UsageMetrics>>, SessionError>

Get the usage metrics collector for a session

Returns a shared reference to the session’s UsageMetrics for command frequency tracking.

Errors

Returns SessionError::NotFound if the session doesn’t exist. Returns SessionError::LockPoisoned if the internal lock is poisoned.

pub fn get_resource_stats( &self, session_id: &SessionId, ) -> Result<(Option<DirStats>, Option<CacheStats>), SessionError>

Get resource statistics for a session

Returns (session_dir_stats, artifact_cache_stats) for the given session.

Errors

Returns SessionError::NotFound if the session doesn’t exist. Returns SessionError::LockPoisoned if the internal lock is poisoned.

pub fn get_subprocess_stats( &self, session_id: &SessionId, ) -> Result<Option<SubprocessMetricsSnapshot>, SessionError>

Get subprocess statistics for a session

Returns subprocess metrics snapshot for the given session.

Errors

Returns SessionError::NotFound if the session doesn’t exist. Returns SessionError::LockPoisoned if the internal lock is poisoned.

pub fn count(&self) -> Result<usize, SessionError>

Get the number of active sessions

Errors

Returns SessionError::LockPoisoned if the internal lock is poisoned.

pub fn exists(&self, session_id: &SessionId) -> Result<bool, SessionError>

Check if a session exists

Errors

Returns SessionError::LockPoisoned if the internal lock is poisoned.

pub fn close_all(&self) -> Result<usize, SessionError>

Close all sessions

Useful for server shutdown. Returns the number of sessions that were closed.

Errors

Returns SessionError::LockPoisoned if the internal lock is poisoned.

Trait Implementations

impl Clone for SessionManager

fn clone(&self) -> SessionManager

Returns a duplicate of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.

impl Debug for SessionManager

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.

impl Default for SessionManager

fn default() -> Self

Returns the “default value” for a type.