Struct RyoStorage 

pub struct RyoStorage { /* private fields */ }

Global RYO storage manager.

Provides high-level API for:

• Dumping session logs
• Loading past sessions
• Querying session history
• Managing imported projects
• Managing storage lifecycle

Implementations

impl RyoStorage

pub const DIR_NAME: &'static str = ".ryo"

Default RYO directory name.

pub const SESSIONS_DIR: &'static str = "sessions"

Sessions subdirectory name.

pub const PROJECTS_DIR: &'static str = "projects"

Projects subdirectory name.

pub const INDEX_FILE: &'static str = "index.json"

Session index file name.

pub const PROJECT_INDEX_FILE: &'static str = "projects.json"

Project index file name.

pub const CACHE_DIR: &'static str = "cache"

Cache subdirectory name.

pub fn global() -> StorageResult<Self>

Create a new storage manager at the default location (~/.ryo/).

pub fn new(root: PathBuf) -> StorageResult<Self>

Create a new storage manager at a custom location.

pub fn with_format(self, format: Format) -> Self

Set the serialization format.

pub fn root(&self) -> &Path

Get the root directory path.

pub fn is_initialized(&self) -> bool

Check if storage is initialized (directories exist).

pub fn init(&self) -> StorageResult<()>

Initialize storage directories.

pub fn ensure_init(&self) -> StorageResult<()>

Ensure storage is initialized, creating directories if needed.

pub fn dump(&mut self, log: &TxLog) -> StorageResult<String>

Dump a session log to storage.

Returns the session ID.

pub fn load(&self, session_id: &str) -> StorageResult<TxLog>

Load a session log by ID.

This method automatically detects the file format by trying all known formats.

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

Check if a session exists (in any format).

pub fn delete(&mut self, session_id: &str) -> StorageResult<()>

Delete a session (in any format).

pub fn index(&mut self) -> StorageResult<&SessionIndex>

Get the session index.

pub fn list_sessions(&mut self) -> StorageResult<Vec<&SessionMeta>>

List all sessions.

pub fn sessions_for_project( &mut self, project_path: &Path, ) -> StorageResult<Vec<&SessionMeta>>

Find sessions by project path.

pub fn latest_session(&mut self) -> StorageResult<Option<&SessionMeta>>

Get the most recent session.

pub fn latest_for_project( &mut self, project_path: &Path, ) -> StorageResult<Option<&SessionMeta>>

Get the most recent session for a project.

pub fn cleanup(&mut self, keep_per_project: usize) -> StorageResult<usize>

Clean up old sessions (keep last N per project).

pub fn storage_size(&self) -> StorageResult<u64>

Get total storage size in bytes.

pub fn project_index(&mut self) -> StorageResult<&ProjectIndex>

Get the project index.

pub fn register_project(&mut self, meta: ProjectMeta) -> StorageResult<String>

Register a project in the index.

pub fn unregister_project( &mut self, project_id: &str, ) -> StorageResult<Option<ProjectMeta>>

Unregister a project from the index.

pub fn get_project( &mut self, project_id: &str, ) -> StorageResult<Option<&ProjectMeta>>

Get a project by ID.

pub fn get_project_by_path( &mut self, path: &Path, ) -> StorageResult<Option<&ProjectMeta>>

Get a project by path.

pub fn get_project_by_path_mut( &mut self, path: &Path, ) -> StorageResult<Option<&mut ProjectMeta>>

Get a mutable project by path.

pub fn save_projects(&self) -> StorageResult<()>

Save the project index (public for external updates).

pub fn search_projects_by_name( &mut self, pattern: &str, ) -> StorageResult<Vec<&ProjectMeta>>

Search projects by name pattern.

pub fn is_project_registered(&mut self, path: &Path) -> StorageResult<bool>

Check if a project path is already registered.

pub fn list_projects(&mut self) -> StorageResult<Vec<&ProjectMeta>>

List all registered projects.

pub fn touch_project(&mut self, project_id: &str) -> StorageResult<()>

Touch a project (update last accessed time).

pub fn project_stats(&mut self) -> StorageResult<(usize, usize, usize)>

Get project statistics.

pub fn cleanup_dead_servers(&mut self) -> StorageResult<usize>

Cleanup dead server PIDs from all projects.

Checks each project’s server_pid and clears it if the process is no longer running. Returns the number of projects that were cleaned up.

pub fn list_projects_with_cleanup( &mut self, cleanup: bool, ) -> StorageResult<Vec<&ProjectMeta>>

List all registered projects, with optional dead server cleanup.

If cleanup is true, dead server PIDs are automatically cleared before listing.

pub fn cache_dir(&self) -> PathBuf

Get the cache directory path.

pub fn save_graph_cache( &self, project_hash: &str, data: &[u8], ) -> StorageResult<PathBuf>

Save a CodeGraph cache.

Returns the cache file path.

pub fn load_graph_cache( &self, project_hash: &str, ) -> StorageResult<Option<Vec<u8>>>

Load a CodeGraph cache.

Returns None if cache doesn’t exist.

pub fn delete_graph_cache(&self, project_hash: &str) -> StorageResult<()>

Delete a CodeGraph cache.

pub fn list_graph_caches(&self) -> StorageResult<Vec<String>>

List all cached project hashes.

pub fn cache_size(&self) -> StorageResult<u64>

Get cache storage size in bytes.

pub fn clear_graph_caches(&self) -> StorageResult<usize>

Clear all graph caches.

Trait Implementations

impl Debug for RyoStorage

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

Formats the value using the given formatter.