Struct MemoryEngine 

pub struct MemoryEngine { /* private fields */ }

Everything that outlives a conversation.

Implementations

impl MemoryEngine

pub fn in_memory(user: UserId) -> Self

An engine backed entirely by in-process storage.

Suitable for tests, single-node deployments and local development; swap the repository and event log for durable ones in production.

pub fn new( user: UserId, repository: Arc<dyn MemoryRepository>, events: Arc<dyn MemoryEventLog>, config: MemoryRuntimeConfig, ) -> Self

An engine over the given repository and event log.

pub fn with_semantic_fallback(self, fallback: Arc<dyn SemanticFallback>) -> Self

Attach a paraphrase-tolerant retrieval backend.

Every session opened afterwards consults it. Without this the seam was unreachable in practice: LocalMemoryRetriever::with_semantic_fallback existed, but MemoryEngine::begin_session built the retriever itself and never called it, so no application could install one.

The backend is asked on both the speculative and the tool path, under the deadlines in crate::core::RetrievalConfig. A backend slower than immediate_semantic_timeout_ms simply times out on the tool path and still contributes through speculation.

pub fn with_plan_extractor( self, extractor: Arc<dyn RetrievalPlanExtractor>, ) -> Self

Use a model-backed retrieval-plan extractor.

The extractor is wrapped in a deadline that falls back to the rule-based plan, so an unavailable model degrades retrieval quality rather than stalling the pipeline.

pub fn with_observation_extractor( self, extractor: Arc<dyn MemoryObservationExtractor>, ) -> Self

Use a model-backed observation extractor, under the configured deadline.

pub fn user(&self) -> &UserId

The user whose memory this engine serves.

pub fn repository(&self) -> &Arc<dyn MemoryRepository>

The canonical repository.

pub fn events(&self) -> &Arc<dyn MemoryEventLog>

The event log.

pub fn config(&self) -> &MemoryRuntimeConfig

Runtime configuration.

pub async fn compile_index(&self) -> Result<u64, MemoryError>

Compile the retrieval index from the canonical corpus.

The index is derived and disposable; this rebuilds it from scratch, which is also the recovery path after any index corruption or schema change.

pub fn begin_session(&self, session_id: SessionId) -> MemorySession

Begin a logical conversation.

pub async fn promote_patterns(&self) -> Result<usize, MemoryError>

Run a promotion sweep over staged patterns.