Struct InMemoryGraphStore 

pub struct InMemoryGraphStore { /* private fields */ }

In-memory GraphStore for tests and benchmarks, with no live backend.

This is the trait’s test/benchmark boundary, letting callers exercise the graph seam without a running FalkorDB. It does not interpret Cypher — there is no graph engine here — so GraphStore::query returns whatever rows were staged via InMemoryGraphStore::stage_rows.

Examples

use memoir_core::graph::{GraphStore, InMemoryGraphStore};

let store = InMemoryGraphStore::new();
store.ensure_graph().await?;
store.stage_rows(vec![vec![("n".to_string(), "Alice".to_string())]]);
let rows = store.query("MATCH (n) RETURN n", &Default::default()).await?;
assert_eq!(rows[0][0].1, "Alice");

Implementations

impl InMemoryGraphStore

pub fn new() -> Self

Creates an empty in-memory graph store.

pub fn stage_rows(&self, rows: GraphRows)

Stages the rows that the next GraphStore::query call returns.

A test affordance: since there is no Cypher engine, this lets a test arrange the result a query observes. Replaces any previously staged rows.

Trait Implementations

impl Default for InMemoryGraphStore

fn default() -> InMemoryGraphStore

Returns the “default value” for a type.

impl GraphStore for InMemoryGraphStore

async fn ensure_graph(&self) -> Result<(), GraphError>

Ensures the configured named graph is reachable.

async fn query( &self, _cypher: &str, _params: &HashMap<String, GraphParam>, ) -> Result<GraphRows, GraphError>

Runs a parameterized Cypher query against the graph, returning its rows.

fn forget_pids( &self, pids: &[&str], ) -> impl Future<Output = Result<(), GraphError>> + Send

Removes each forgotten pid from the graph, reference-counted.

fn forget_scope( &self, scope: &Scope, ) -> impl Future<Output = Result<(), GraphError>> + Send

Deletes every node and edge in scope — a whole-tenant forget.

fn commit_triples<EM, ER, EdgeR>( &self, embedder: &EM, entities: &ER, edges: &EdgeR, ctx: &CommitContext, triples: &TripleSet, ) -> impl Future<Output = Result<usize, CommitError>> + Send

where EM: EmbeddingModel, ER: EntityResolver, EdgeR: EdgeResolver,

Commits a source’s resolved triples to the graph, returning the count.

fn neighbors( &self, seed_pids: &[&str], scope: &Scope, depth: usize, ) -> impl Future<Output = Result<GraphContext, GraphError>> + Send

Returns the graph neighborhood around a set of seed memories.

fn inspect_scope( &self, agent_id: Option<&str>, org_id: Option<&str>, user_id: Option<&str>, limit: usize, ) -> impl Future<Output = Result<GraphSnapshot, GraphError>> + Send

Returns a whole-scope snapshot of the graph for admin inspection.