Struct SqliteBackend 

pub struct SqliteBackend { /* private fields */ }

SQLite-based storage backend

This implements the StorageBackend trait using SQLite as the underlying database. It wraps the existing Storage struct and delegates to the functions in queries.rs.

Implementations

impl SqliteBackend

pub fn new(config: StorageConfig) -> Result<Self>

Create a new SQLite backend with the given configuration

pub fn in_memory() -> Result<Self>

Create an in-memory SQLite backend (useful for testing)

pub fn storage(&self) -> &Storage

Get a reference to the underlying Storage

pub fn storage_mut(&mut self) -> &mut Storage

Get a mutable reference to the underlying Storage

Trait Implementations

impl CloudSyncBackend for SqliteBackend

fn push(&self) -> Result<SyncResult>

Push changes to cloud

fn pull(&self) -> Result<SyncResult>

Pull changes from cloud

fn sync_delta(&self, since_version: u64) -> Result<SyncDelta>

Get delta changes since version

fn sync_state(&self) -> Result<SyncState>

Get current sync state

fn force_sync(&self) -> Result<SyncResult>

Force a full sync (push then pull)

impl StorageBackend for SqliteBackend

fn create_memory(&self, input: CreateMemoryInput) -> Result<Memory>

Create a new memory

fn get_memory(&self, id: MemoryId) -> Result<Option<Memory>>

Get a memory by ID

fn update_memory( &self, id: MemoryId, input: UpdateMemoryInput, ) -> Result<Memory>

Update a memory

fn delete_memory(&self, id: MemoryId) -> Result<()>

Delete a memory (soft delete)

fn create_memories_batch( &self, inputs: Vec<CreateMemoryInput>, ) -> Result<BatchCreateResult>

Create multiple memories in a single transaction

fn delete_memories_batch(&self, ids: Vec<MemoryId>) -> Result<BatchDeleteResult>

Delete multiple memories in a single transaction

fn list_memories(&self, options: ListOptions) -> Result<Vec<Memory>>

List memories with filters

fn count_memories(&self, options: ListOptions) -> Result<i64>

Count memories matching filters

fn search_memories( &self, query: &str, options: SearchOptions, ) -> Result<Vec<SearchResult>>

Search memories using hybrid search

fn create_crossref( &self, from_id: MemoryId, to_id: MemoryId, edge_type: EdgeType, score: f32, ) -> Result<CrossReference>

Create a cross-reference between memories

fn get_crossrefs(&self, memory_id: MemoryId) -> Result<Vec<CrossReference>>

Get cross-references for a memory

fn delete_crossref(&self, from_id: MemoryId, to_id: MemoryId) -> Result<()>

Delete a cross-reference

fn list_tags(&self) -> Result<Vec<(String, i64)>>

List all tags with usage counts

fn get_memories_by_tag( &self, tag: &str, limit: Option<usize>, ) -> Result<Vec<Memory>>

Get memories with a specific tag

fn list_workspaces(&self) -> Result<Vec<(String, i64)>>

List all workspaces with memory counts

fn get_workspace_stats(&self, workspace: &str) -> Result<HashMap<String, i64>>

Get detailed statistics for a workspace

fn move_to_workspace( &self, ids: Vec<MemoryId>, workspace: &str, ) -> Result<usize>

Move memories to a different workspace

fn get_stats(&self) -> Result<StorageStats>

Get storage statistics

fn health_check(&self) -> Result<HealthStatus>

Check storage health

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

Run optimization (e.g., VACUUM)

fn backend_name(&self) -> &'static str

Get backend name identifier

fn schema_version(&self) -> Result<i32>

Get current schema version

impl TransactionalBackend for SqliteBackend

fn with_transaction<F, T>(&self, f: F) -> Result<T>

where F: FnOnce(&dyn StorageBackend) -> Result<T>,

Execute a closure within a transaction

fn savepoint(&self, name: &str) -> Result<()>

create a savepoint

fn release_savepoint(&self, name: &str) -> Result<()>

release a savepoint

fn rollback_to_savepoint(&self, name: &str) -> Result<()>

rollback to a savepoint