Struct InMemoryFacts 

pub struct InMemoryFacts { /* private fields */ }

Implementations

impl InMemoryFacts

pub fn seed(&self, fact: Fact)

Insert a fact bypassing save (no async, no Result) — used to seed fixtures before the use case runs.

pub fn get_clone(&self, id: &FactId) -> Option<Fact>

Read-only snapshot of a stored fact by id.

pub fn script_dedup_hits(&self, hits: Vec<SearchHit>)

Program the response returned by search_for_dedup.

pub fn script_search_hits(&self, hits: Vec<SearchHit>)

Program the response returned by search_similar. Used by EnrichRequest::execute unit tests to push vector-search survivors into the rerank stage.

pub fn is_empty(&self) -> bool

pub fn contains(&self, id: &FactId) -> bool

Trait Implementations

impl Clone for InMemoryFacts

fn clone(&self) -> InMemoryFacts

Returns a duplicate of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.

impl Default for InMemoryFacts

fn default() -> InMemoryFacts

Returns the “default value” for a type.

impl FactRepository for InMemoryFacts

async fn save(&self, fact: &Fact) -> Result<(), RepoError>

Insert or replace a fact (idempotent by FactId).

async fn get( &self, id: &FactId, _memory_key: &MemoryKey, ) -> Result<Option<Fact>, RepoError>

Look up a fact by id within a memory namespace.

async fn list_accepted( &self, _memory_key: &MemoryKey, ) -> Result<Vec<Fact>, RepoError>

All currently-accepted facts in a namespace (§3 retrieval pool).

async fn list_pending( &self, _memory_key: &MemoryKey, ) -> Result<Vec<Fact>, RepoError>

All currently-pending facts in a namespace (§5 session-end input).

async fn list_memory_keys_for_session( &self, session_id: &SessionId, ) -> Result<Vec<MemoryKey>, RepoError>

Distinct memory_keys whose fact set references session_id in source_sessions.

async fn list_memory_keys(&self) -> Result<Vec<MemoryKey>, RepoError>

Distinct memory_key values across every namespace in the store.

async fn search_similar( &self, _embedding: Vec<f32>, _memory_key: &MemoryKey, _limit: usize, ) -> Result<Vec<SearchHit>, RepoError>

K-nearest-neighbour vector search against accepted facts.

async fn search_for_dedup( &self, _embedding: Vec<f32>, _memory_key: &MemoryKey, _limit: usize, ) -> Result<Vec<SearchHit>, RepoError>

Semantic-dedup search across pending AND accepted facts (no tombstones). Used by the extraction pipeline’s safety-net Layer 2 (persist_facts step 2): a rephrased re-observation hashes to a different FactId, so the exact match misses — but the embedding is still near-identical and a cross-session confirmation can promote the existing fact past the accept threshold.

async fn update_heat_batch( &self, _ids: &[FactId], _memory_key: &MemoryKey, _heat_base: Heat, _last_access: Timestamp, ) -> Result<(), RepoError>

Bulk-rewrite heat fields for a set of facts (§7 retrieval rewarm).