Struct SqliteMemoryStore 

pub struct SqliteMemoryStore { /* private fields */ }

SQLite-backed memory store.

Implements MemoryBackend for the memory_* agent tools. Each memory is stored with an auto-generated UUID, kind, content, and subject. The schema reserves an embedding column for future cosine-search support.

Implementations

impl SqliteMemoryStore

pub fn open(path: &Path) -> Result<Self, Error>

Open or create a SQLite memory store at path.

Uses :memory: for an in-memory database. For persistent paths, filesystem-aware journal-mode selection is applied (see oxi_mnemopi::journal::JournalMode). On network filesystems the engine falls back to TRUNCATE mode + per-host DB sibling to avoid SIGBUS from mmap’d -shm.

Trait Implementations

impl Debug for SqliteMemoryStore

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

Formats the value using the given formatter.

impl MemoryBackend for SqliteMemoryStore

fn clear_all<'a>( &'a self, ) -> Pin<Box<dyn Future<Output = Result<usize, ToolError>> + Send + 'a>>

Bulk delete: a single SQL statement, no per-row round-trip. Returns the number of rows removed across all subjects.

fn enqueue_consolidation<'a>( &'a self, ) -> Pin<Box<dyn Future<Output = Result<String, ToolError>> + Send + 'a>>

No background pipeline: surface an honest “not supported” rather than claiming to have enqueued work that did not happen.

fn put<'a>( &'a self, content: &'a str, kind: &'a str, subject: &'a str, ) -> Pin<Box<dyn Future<Output = Result<String, ToolError>> + Send + 'a>>

Store a memory item, returning its new ID.

fn search<'a>( &'a self, query: &'a str, k: usize, ) -> Pin<Box<dyn Future<Output = Result<Vec<MemoryItem>, ToolError>> + Send + 'a>>

Semantic-search stored memories, returning up to k matches.

fn list<'a>( &'a self, subject: &'a str, ) -> Pin<Box<dyn Future<Output = Result<Vec<MemoryItem>, ToolError>> + Send + 'a>>

List memory items for the given subject.

fn delete<'a>( &'a self, id: &'a str, ) -> Pin<Box<dyn Future<Output = Result<(), ToolError>> + Send + 'a>>

Delete the memory item with the given ID.

fn memory_info(&self) -> Option<String>

Human-readable memory status (None if not supported by this backend).

fn trigger_consolidation(&self) -> Option<String>

Trigger sleep consolidation, returning a status message.

fn trigger_harmonize(&self) -> Option<String>

Trigger SHMR harmonization, returning a status message.