Struct SqliteIndex 

pub struct SqliteIndex { /* private fields */ }

SQLite-based file index

Implementations

impl SqliteIndex

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

Create a new SQLite index at the given path

pub async fn load(db_path: PathBuf) -> Result<Self>

Load index from existing database (alias for new)

pub async fn get( &self, id: &str, include_deleted: bool, ) -> Result<Option<FileIndexEntry>>

Get an entry by ID

Arguments

• id - The file ID
• include_deleted - If true, include soft-deleted files

pub async fn soft_delete( &self, id: &str, deleted_by: Option<&str>, ) -> Result<bool>

Soft delete a file by ID

Marks the file as deleted but does not remove it physically. The file can be restored until the retention period expires.

pub async fn restore(&self, id: &str) -> Result<bool>

Restore a soft-deleted file

Clears the deleted_at timestamp, making the file accessible again.

pub async fn list_deleted(&self) -> Result<Vec<FileIndexEntry>>

List all soft-deleted files

pub async fn get_expired_deletions( &self, retention_days: u32, ) -> Result<Vec<FileIndexEntry>>

Get soft-deleted files that are ready for permanent deletion

Arguments

• retention_days - Files deleted more than this many days ago

pub async fn hard_delete(&self, id: &str) -> Result<Option<FileIndexEntry>>

Hard delete a file (physical removal from database)

Use with caution - this permanently removes the index entry. The actual file data should be deleted separately.

pub async fn insert(&self, entry: FileIndexEntry) -> Result<()>

Insert or update an entry

pub async fn remove(&self, id: &str) -> Result<Option<FileIndexEntry>>

Remove an entry by ID

This physically removes the entry from the database. Note: For soft delete, use soft_delete() instead.

pub async fn update_ref_count( &self, id: &str, delta: i32, ) -> Result<Option<usize>>

Update reference count for an entry

Arguments

• id - The file ID
• delta - Change in reference count (+1 to add, -1 to release)

Returns

The new reference count, or None if the entry doesn’t exist

pub async fn get_candidates_for_cleanup( &self, threshold: i32, max_age_days: u32, ) -> Result<Vec<FileIndexEntry>>

Get entries suitable for cleanup

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

Get total entry count

pub async fn is_empty(&self) -> Result<bool>

Check if index is empty

pub async fn entries(&self) -> Result<Vec<FileIndexEntry>>

Get all entries (use sparingly with large datasets)

pub async fn stats(&self) -> Result<IndexStats>

Get statistics about the index

pub async fn close(&self)

Close the database connection

pub async fn migrate_from_jsonl(&self, jsonl_path: &Path) -> Result<usize>

Migrate from old JSONL format