Struct DiskStorage 

pub struct DiskStorage { /* private fields */ }

File-based storage implementation.

Implementations

impl DiskStorage

pub fn new(root_dir: PathBuf) -> Result<Self>

Create a new disk storage instance.

pub fn with_options(root_dir: PathBuf, options: StorageOptions) -> Result<Self>

Create a new disk storage with custom options.

Trait Implementations

impl Storage for DiskStorage

fn init_workspace( &self, workspace_id: &WorkspaceId, root_path: &PathBuf, ) -> Result<()>

Initialize storage for a workspace.

fn workspace_exists(&self, workspace_id: &WorkspaceId) -> bool

Check if a workspace exists.

fn load_workspace_metadata( &self, workspace_id: &WorkspaceId, ) -> Result<WorkspaceMetadata>

Load workspace metadata.

fn save_workspace_metadata( &self, workspace_id: &WorkspaceId, metadata: &WorkspaceMetadata, ) -> Result<()>

Save workspace metadata.

fn save_documents( &self, workspace_id: &WorkspaceId, documents: &[Document], ) -> Result<()>

Save documents for a workspace.

fn load_documents(&self, workspace_id: &WorkspaceId) -> Result<Vec<Document>>

Load all documents for a workspace.

fn save_chunks( &self, workspace_id: &WorkspaceId, chunks: &[Chunk], ) -> Result<()>

Save chunks for a workspace.

fn load_chunks(&self, workspace_id: &WorkspaceId) -> Result<Vec<Chunk>>

Load all chunks for a workspace.

fn save_embeddings( &self, workspace_id: &WorkspaceId, embeddings: &[(String, Vec<f32>)], ) -> Result<()>

Save embeddings for chunks.

fn load_embeddings( &self, workspace_id: &WorkspaceId, ) -> Result<Vec<(String, Vec<f32>)>>

Load embeddings for a workspace.

fn tantivy_index_path(&self, workspace_id: &WorkspaceId) -> PathBuf

Get the path to the tantivy index directory.

fn vector_index_path(&self, workspace_id: &WorkspaceId) -> PathBuf

Get the path to the vector index.

fn delete_workspace(&self, workspace_id: &WorkspaceId) -> Result<()>

Delete a workspace and all its data.

fn list_workspaces(&self) -> Result<Vec<WorkspaceId>>

List all stored workspaces.

fn get_workspace_stats( &self, workspace_id: &WorkspaceId, ) -> Result<WorkspaceStats>

Get workspace statistics.

fn flush(&self) -> Result<()>

Flush any pending writes to disk.