Struct MemoryStore 

pub struct MemoryStore { /* private fields */ }

Implementations

impl MemoryStore

pub async fn get_status(&self) -> Result<StoreStatus>

Extended store statistics (counts, categories, top memories, task metrics).

pub async fn list_memories( &self, category: Option<MemoryCategory>, ) -> Result<Vec<MemoryRecord>>

List memories, optionally filtered by category.

pub async fn list_tasks(&self, limit: u32) -> Result<Vec<TaskRecord>>

List recent tasks with retrievals and memories created during each task.

pub async fn get_timeline(&self, limit: u32) -> Result<Vec<TimelineEvent>>

Merged timeline of tasks and memory events.

pub async fn search_memories(&self, query: &str) -> Result<Vec<Memory>>

Read-only semantic search — no task record, no retrieval side effects.

pub async fn search(&self, query: &str) -> Result<StartTaskResult>

Semantic search via full task lifecycle (creates a task record).

impl MemoryStore

pub async fn report(&self, input: MemoryReportInput) -> Result<String>

Unified memory report (correction, user input, or insight).

pub async fn end_task_with_decay( &self, task_id: &str, input: TaskEndInput, ) -> Result<EndTaskWithDecayResult>

End task and run weight decay.

pub async fn contradict( &self, memory_id: &str, correction: Option<&str>, ) -> Result<ContradictResult>

Flag a memory as wrong and optionally store a correction.

impl MemoryStore

pub fn new(config: MemzConfig, embed: EmbedFn) -> Self

pub fn dimensions(&self) -> u32

pub async fn init(&self) -> Result<()>

pub async fn start_task(&self, description: &str) -> Result<StartTaskResult>

pub async fn report_correction( &self, input: ReportCorrectionInput, ) -> Result<String>

pub async fn report_user_input(&self, input: ReportUserInput) -> Result<String>

pub async fn end_task(&self, task_id: &str, input: TaskEndInput) -> Result<()>

pub async fn decay(&self) -> Result<DecayResult>

pub async fn purge(&self, threshold: f64) -> Result<u32>

pub async fn get_stats(&self) -> Result<MemoryStats>

pub async fn get_top_by_weight(&self, limit: u32) -> Result<Vec<Memory>>

pub async fn insert_raw_memory( &self, content: &str, category: MemoryCategory, weight: f64, ) -> Result<String>

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

pub async fn contradict_memory( &self, memory_id: &str, correction: Option<&str>, ) -> Result<(bool, Option<String>)>

pub async fn penalize_memory(&self, memory_id: &str, factor: f64) -> Result<()>

pub async fn close(&self) -> Result<()>