Struct MemoryService 

pub struct MemoryService {
    pub lance: LanceStore,
    pub embedder: Mutex<Embedder>,
    pub auto_recall: bool,
}

Graph-based memory service owning LanceDB entity, relation, and journal storage.

Fields

lance: LanceStore

embedder: Mutex<Embedder>

auto_recall: bool

Implementations

impl MemoryService

pub async fn open( memory_dir: impl AsRef<Path>, config: &MemoryConfig, ) -> Result<Self>

Create a new MemoryService, opening or creating the LanceDB database.

pub async fn embed(&self, text: &str) -> Result<Vec<f32>>

Generate an embedding vector for text. Runs candle inference in a blocking task.

pub fn memory_prompt() -> &'static str

Return the memory prompt to append to agent system prompts.

pub async fn unified_search(&self, query: &str, limit: usize) -> Option<String>

Unified search: embed query → semantic entity search → 1-hop graph on top-3 → format.

Shared by dispatch_recall (per query) and handle_before_run (auto-recall). Returns None when no results are found.

pub async fn dispatch_recall(&self, args: &str) -> String

Dispatch the recall tool call — batch queries via unified_search.

pub async fn dispatch_extract(&self, args: &str) -> String

Dispatch the extract tool call — batch upsert entities + relations.

pub async fn dispatch_journal(&self, args: &str, agent: &str) -> String

Internal dispatch for storing a journal entry.

Called by the agent loop after compaction — args is the raw summary text.