Struct StreamingGraphRag 

pub struct StreamingGraphRag { /* private fields */ }

A live-updating GraphRAG engine that processes streaming triple events and serves subgraph queries from a cache backed by the live graph.

Implementations

impl StreamingGraphRag

pub fn new(max_depth: usize) -> Self

Create a new engine.

• max_depth – BFS depth for subgraph extraction
• cache_ttl_ms is ignored if 0 (no expiry)

pub fn with_cache_ttl(max_depth: usize, cache_ttl_ms: i64) -> Self

Create with an explicit cache TTL in milliseconds (0 = no expiry).

pub fn process_event(&mut self, s: &str, p: &str, o: &str)

Process an incoming triple event (always treated as “add”).

pub fn query_live( &mut self, pattern: &SubgraphPattern, ) -> Vec<(String, String, String)>

Query the live graph using pattern, returning cached results when fresh.

pub fn stats(&self) -> StreamingStats

Return current statistics.

pub fn drain_events(&mut self) -> Vec<SubgraphEvent>

Drain buffered events from the underlying extractor.