Struct MnemopiMemoryBackend 

pub struct MnemopiMemoryBackend { /* private fields */ }

Wraps an oxicode_mnemopi::Mnemopi engine and exposes it through the MemoryBackend trait used by the memory_* agent tools.

Implementations

impl MnemopiMemoryBackend

pub fn open( path: &Path, session_id: &str, embedding_provider: Option<Arc<dyn EmbeddingProvider>>, embedding_model_name: &str, ) -> Result<Self, String>

Open or create a Mnemopi-backed memory store at path.

embedding_provider is the optional dense-vector model. When Some, Mnemopi::remember/recall will auto-embed every stored fact and recall query, activating the dense cosine-similarity signal of the hybrid scoring formula. When None, recall runs in FTS5-only mode.

embedding_model_name is the logical model identifier recorded alongside each stored embedding (used for cache keying and diagnostics). Pass an empty string when no provider is wired.

impl MnemopiMemoryBackend

pub fn engine(&self) -> &Mnemopi

Get a reference to the underlying engine.

pub async fn sleep(&self, ttl_hours: i64, dry_run: bool) -> Result<(), String>

Run sleep consolidation.

pub async fn harmonize(&self) -> Result<String, String>

Run SHMR harmonization.

pub fn stats(&self) -> SessionStats

Get session stats (synchronous).

pub fn should_auto_sleep(&self, threshold: usize) -> bool

Check if auto-sleep should trigger.

pub async fn maybe_auto_sleep(&self, threshold: usize) -> Result<bool, String>

Run auto-sleep if threshold is exceeded.

Trait Implementations

impl Debug for MnemopiMemoryBackend

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

Formats the value using the given formatter.

impl MemoryBackend for MnemopiMemoryBackend

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

Bulk erase via the underlying SQLite connection: working_memory, episodic_memory, and memory_embeddings. The FTS5 indices are rebuilt by their existing triggers when rows are removed. Uses Mnemopi::spawn_blocking so the call is safe from any async context (the closure runs on the blocking pool; the

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

Real consolidation trigger: run a synchronous sleep pass through the engine. The Mnemopi facade already owns the SQLite handle, so this is the correct level for the operation — no separate pipeline DB is needed for an immediate consolidation pass.

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.