Struct GraphMemory 

pub struct GraphMemory { /* private fields */ }

The main entry point for graph memory operations.

Implementations

impl GraphMemory

pub async fn open(path: &Path) -> Result<Self, GraphError>

Open or create a graph store at the given path. Path should be the graph/ directory inside the memory directory.

pub fn path(&self) -> &Path

Path to the graph store.

pub async fn add_entity(&self, entity: NewEntity) -> Result<Entity, GraphError>

Add a new entity to the graph.

pub async fn get_entity(&self, name: &str) -> Result<Option<Entity>, GraphError>

Get an entity by name.

pub async fn get_entity_by_id( &self, id: &str, ) -> Result<Option<Entity>, GraphError>

Get an entity by its record ID.

pub async fn update_entity( &self, id: &str, updates: EntityUpdate, ) -> Result<Entity, GraphError>

Update an entity’s fields.

pub async fn delete_entity(&self, id: &str) -> Result<(), GraphError>

Delete an entity and its relationships.

pub async fn list_entities( &self, entity_type: Option<&str>, ) -> Result<Vec<Entity>, GraphError>

List all entities, optionally filtered by type.

pub async fn add_relationship( &self, rel: NewRelationship, ) -> Result<Relationship, GraphError>

Create a relationship between two named entities.

pub async fn get_relationships( &self, entity_name: &str, direction: Direction, ) -> Result<Vec<Relationship>, GraphError>

Get relationships for an entity.

pub async fn supersede_relationship( &self, old_id: &str, new: NewRelationship, ) -> Result<Relationship, GraphError>

Supersede a relationship: close the old one, create a new one.

pub async fn add_episode( &self, episode: NewEpisode, ) -> Result<Episode, GraphError>

Add a new episode to the graph.

pub async fn get_episodes_by_session( &self, session_id: &str, ) -> Result<Vec<Episode>, GraphError>

Get episodes by session ID.

pub async fn get_episode_by_log_number( &self, log_number: u32, ) -> Result<Option<Episode>, GraphError>

Get episode by log number.

pub async fn ingest_archive( &self, archive_text: &str, session_id: &str, log_number: Option<u32>, llm: Option<&dyn LlmProvider>, ) -> Result<IngestionReport, GraphError>

Ingest a conversation archive into the knowledge graph.

pub async fn extract_from_archive( &self, archive_text: &str, session_id: &str, log_number: Option<u32>, llm: &dyn LlmProvider, ) -> Result<IngestionReport, GraphError>

Run LLM extraction on an archive without creating episodes.

pub async fn mark_extracted(&self, log_number: u32) -> Result<(), GraphError>

Mark all episodes with a given log_number as extracted.

pub async fn unextracted_log_numbers(&self) -> Result<Vec<i64>, GraphError>

Get log numbers of episodes that have NOT been extracted.

pub async fn search( &self, query: &str, limit: usize, ) -> Result<Vec<SearchResult>, GraphError>

Semantic search across entities (legacy — returns full Entity).

pub async fn search_with_options( &self, query: &str, options: &SearchOptions, ) -> Result<Vec<ScoredEntity>, GraphError>

Search with options — L1 projections, type/keyword filters.

pub async fn search_episodes( &self, query: &str, limit: usize, ) -> Result<Vec<EpisodeSearchResult>, GraphError>

Semantic search across episodes.

pub async fn query( &self, query_text: &str, options: &QueryOptions, ) -> Result<QueryResult, GraphError>

Hybrid query: semantic + graph expansion + optional episode search.

pub async fn traverse( &self, entity_name: &str, depth: u32, ) -> Result<TraversalNode, GraphError>

Traverse the graph from a named entity.

pub async fn traverse_filtered( &self, entity_name: &str, depth: u32, type_filter: Option<&str>, ) -> Result<TraversalNode, GraphError>

Traverse with type filter.

pub async fn sync_pipeline( &self, docs: &PipelineDocuments, ) -> Result<PipelineSyncReport, GraphError>

Sync pipeline documents into the graph.

pub async fn pipeline_stats( &self, staleness_days: u32, ) -> Result<PipelineGraphStats, GraphError>

Get pipeline stats from the graph.

pub async fn pipeline_entities( &self, stage: &str, status: Option<&str>, ) -> Result<Vec<EntityDetail>, GraphError>

Get pipeline entities by stage and optional status.

pub async fn pipeline_flow( &self, entity_name: &str, ) -> Result<Vec<(EntityDetail, String, EntityDetail)>, GraphError>

Trace pipeline flow for an entity.

pub async fn sync_vigil_signals( &self, signals_path: &Path, ) -> Result<VigilSyncReport, GraphError>

Sync vigil signal vectors into the graph as Measurement entities.

pub async fn sync_outcomes( &self, outcomes_path: &Path, ) -> Result<VigilSyncReport, GraphError>

Sync outcome records into the graph as Outcome entities.

pub async fn sync_vigil( &self, signals_path: &Path, outcomes_path: &Path, ) -> Result<VigilSyncReport, GraphError>

Sync both vigil signals and outcomes in one call.

pub async fn stats(&self) -> Result<GraphStats, GraphError>

Get graph statistics.