Struct FederatedGraphRag 

pub struct FederatedGraphRag { /* private fields */ }

Multi-node GraphRAG federation manager.

In production this would issue async HTTP requests to remote endpoints; here remote nodes are simulated by the local engine (each node shares the same local corpus but is given a distinct source label).

Implementations

impl FederatedGraphRag

pub fn new(strategy: FederationStrategy) -> Self

Create a new federation with the given routing strategy.

pub fn add_node(&mut self, node: FederationNode)

Add a remote node to the federation.

pub fn remove_node(&mut self, node_id: &str) -> bool

Remove a node by its ID. Returns true if the node existed.

pub fn query(&mut self, q: &FederatedQuery) -> FederatedResult

Execute a federated query and return the merged result.

pub fn healthy_nodes(&self) -> Vec<&FederationNode>

Return references to all currently healthy nodes.

pub fn mark_unhealthy(&mut self, node_id: &str)

Mark a node as unhealthy (e.g. after a failed health check).

pub fn rebalance(&mut self)

Rebalance: restore all nodes to healthy (simulates health-check recovery).

pub fn add_corpus_passage(&mut self, text: impl Into<String>, base_score: f64)

Add a passage to the local corpus (used as backing store for all nodes in the simulation).

pub fn node_count(&self) -> usize

Number of nodes in the federation (healthy + unhealthy).