Struct SessionManager 

pub struct SessionManager { /* private fields */ }

Manager for session persistence and lifecycle.

The SessionManager provides file-based persistence for sessions, storing them in {workspace}/.thulp/sessions/ as JSON files.

Example

use thulp_workspace::{Workspace, SessionManager, SessionType};

let workspace = Workspace::new("my-workspace", "My Workspace", PathBuf::from("."));
let manager = SessionManager::new(&workspace).await?;

let session = manager.create_session("My Session", SessionType::Conversation {
    purpose: "Testing".to_string(),
}).await?;

manager.add_entry(&session.id(), EntryType::UserMessage, json!({"text": "Hello"})).await?;

Implementations

impl SessionManager

pub async fn new(workspace: &Workspace) -> Result<Self>

Create a new session manager for the given workspace.

This will create the sessions directory if it doesn’t exist.

pub async fn with_sessions_dir(sessions_dir: PathBuf) -> Result<Self>

Create a new session manager with a custom sessions directory.

pub async fn create_session( &self, name: impl Into<String>, session_type: SessionType, ) -> Result<Session>

Create a new session.

The session is automatically persisted to disk and cached in memory.

pub async fn load_session(&self, id: &SessionId) -> Result<Session>

Load a session from disk.

If the session is already cached in memory, returns the cached version.

pub async fn save_session(&self, session: &Session) -> Result<()>

Save a session to disk.

pub async fn add_entry( &self, session_id: &SessionId, entry_type: EntryType, content: Value, ) -> Result<SessionEntry>

Add an entry to a session.

The session is automatically saved after adding the entry.

pub async fn complete_session(&self, session_id: &SessionId) -> Result<()>

Complete a session.

Marks the session as completed and saves it.

pub async fn fail_session(&self, session_id: &SessionId) -> Result<()>

Fail a session.

Marks the session as failed and saves it.

pub async fn cancel_session(&self, session_id: &SessionId) -> Result<()>

Cancel a session.

Marks the session as cancelled and saves it.

pub async fn pause_session(&self, session_id: &SessionId) -> Result<()>

Pause a session.

Marks the session as paused and saves it.

pub async fn resume_session(&self, session_id: &SessionId) -> Result<()>

Resume a paused session.

Marks the session as active and saves it.

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

List all sessions, optionally filtered.

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

Delete a session.

Removes the session from disk and cache.

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

Check if a session exists.

pub async fn peek_session(&self, session_id: &SessionId) -> Result<Session>

Get a session without loading it into cache.

Useful for one-off reads where caching isn’t beneficial.

pub async fn evict_from_cache(&self, session_id: &SessionId)

Evict a session from the in-memory cache.

The session remains on disk but is removed from memory.

pub async fn clear_cache(&self)

Clear all sessions from the in-memory cache.

pub async fn cached_session_count(&self) -> usize

Get the number of cached sessions.

pub async fn active_sessions(&self) -> Vec<Session>

Get all active sessions (in-memory only).

pub async fn find_by_tag(&self, tag: &str) -> Result<Vec<SessionMetadata>>

Find sessions by tag.

pub async fn find_by_type( &self, session_type_name: &str, ) -> Result<Vec<SessionMetadata>>

Find sessions by type.

pub async fn find_by_status( &self, status: SessionStatus, ) -> Result<Vec<SessionMetadata>>

Find sessions by status.

pub async fn find_created_after( &self, timestamp: Timestamp, ) -> Result<Vec<SessionMetadata>>

Find sessions created after a timestamp.

pub async fn find_updated_after( &self, timestamp: Timestamp, ) -> Result<Vec<SessionMetadata>>

Find sessions updated after a timestamp.

pub async fn session_count(&self) -> Result<usize>

Get session count on disk.

Trait Implementations

impl Debug for SessionManager

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

Formats the value using the given formatter.