Struct LineageGraph 

pub struct LineageGraph { /* private fields */ }

The Lineage Graph - stores and infers causal relationships

Implementations

impl LineageGraph

pub fn new(db: Arc<DB>) -> Self

Create a new lineage graph backed by RocksDB

pub fn with_config(db: Arc<DB>, config: InferenceConfig) -> Self

Create with custom inference config

pub fn store_edge(&self, user_id: &str, edge: &LineageEdge) -> Result<()>

Store a lineage edge

pub fn get_edge( &self, user_id: &str, edge_id: &str, ) -> Result<Option<LineageEdge>>

Get an edge by ID

pub fn delete_edge(&self, user_id: &str, edge_id: &str) -> Result<bool>

Delete an edge (for rejection)

pub fn get_edges_from( &self, user_id: &str, memory_id: &MemoryId, ) -> Result<Vec<LineageEdge>>

Get all edges from a memory (outgoing)

pub fn get_edges_to( &self, user_id: &str, memory_id: &MemoryId, ) -> Result<Vec<LineageEdge>>

Get all edges to a memory (incoming)

pub fn list_edges( &self, user_id: &str, limit: usize, ) -> Result<Vec<LineageEdge>>

List all edges for a user

pub fn store_branch(&self, user_id: &str, branch: &LineageBranch) -> Result<()>

Store a branch

pub fn get_branch( &self, user_id: &str, branch_id: &str, ) -> Result<Option<LineageBranch>>

Get a branch by ID

pub fn list_branches(&self, user_id: &str) -> Result<Vec<LineageBranch>>

List all branches for a user

pub fn create_branch( &self, user_id: &str, name: &str, parent_branch: &str, branch_point: MemoryId, description: Option<&str>, ) -> Result<LineageBranch>

Create a new branch from current state

pub fn ensure_main_branch(&self, user_id: &str) -> Result<()>

Ensure main branch exists for user

pub fn infer_relation( &self, from: &Memory, to: &Memory, ) -> Option<(CausalRelation, f32)>

Infer causal relationship between two memories

pub fn detect_branch_signal(content: &str) -> bool

Detect branch point from memory content (pivot language)

pub fn trace( &self, user_id: &str, memory_id: &MemoryId, direction: TraceDirection, max_depth: usize, ) -> Result<LineageTrace>

Trace lineage from a memory

pub fn find_root_cause( &self, user_id: &str, memory_id: &MemoryId, ) -> Result<Option<MemoryId>>

Find the root cause of a memory (trace all the way back)

pub fn find_effects( &self, user_id: &str, memory_id: &MemoryId, max_depth: usize, ) -> Result<Vec<MemoryId>>

Find all effects of a memory (trace all the way forward)

pub fn confirm_edge(&self, user_id: &str, edge_id: &str) -> Result<bool>

Confirm an inferred edge

pub fn reject_edge(&self, user_id: &str, edge_id: &str) -> Result<bool>

Reject (delete) an inferred edge

pub fn add_explicit_edge( &self, user_id: &str, from: MemoryId, to: MemoryId, relation: CausalRelation, ) -> Result<LineageEdge>

Add an explicit edge

pub fn edge_exists( &self, user_id: &str, from: &MemoryId, to: &MemoryId, ) -> Result<bool>

Check if an edge already exists between two memories

pub fn stats(&self, user_id: &str) -> Result<LineageStats>

Get lineage statistics for a user