Expand description
Streaming subgraph extraction using SPARQL-like patterns.
§Overview
StreamingSubgraphExtractor maintains an in-memory adjacency graph built
from (subject, predicate, object) triples added or removed at runtime.
It emits SubgraphEvents whenever the graph changes, and provides pattern-
based subgraph extraction.
StreamingGraphRag wraps the extractor and adds a query-result cache with
a configurable TTL, tracking hit-rate statistics.
Structs§
- Streaming
Graph Rag - A live-updating GraphRAG engine that processes streaming triple events and serves subgraph queries from a cache backed by the live graph.
- Streaming
Stats - Runtime statistics for
StreamingGraphRag. - Streaming
Subgraph Extractor - In-memory streaming subgraph manager.
- Subgraph
Event - A single event emitted by
StreamingSubgraphExtractor. - Subgraph
Pattern - Describes which subgraph to extract from the live graph.
Enums§
- Subgraph
Event Type - Describes what changed in the streaming subgraph.
- Subgraph
Filter - Predicate filter for neighbourhood expansion.