Struct ClusterManager 

pub struct ClusterManager { /* private fields */ }

Manages a distributed cluster of vector database nodes

Implementations

impl ClusterManager

pub fn new( config: ClusterConfig, node_id: String, discovery: Box<dyn DiscoveryService>, ) -> Result<Self>

Create a new cluster manager

pub async fn add_node(&self, node: ClusterNode) -> Result<()>

Add a node to the cluster

pub async fn remove_node(&self, node_id: &str) -> Result<()>

Remove a node from the cluster

pub fn get_node(&self, node_id: &str) -> Option<ClusterNode>

Get node by ID

pub fn list_nodes(&self) -> Vec<ClusterNode>

List all nodes in the cluster

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

Get healthy nodes only

pub fn get_shard(&self, shard_id: u32) -> Option<ShardInfo>

Get shard information

pub fn list_shards(&self) -> Vec<ShardInfo>

List all shards

pub fn assign_shard(&self, shard_id: u32) -> Result<ShardInfo>

Assign a shard to nodes using consistent hashing

pub async fn run_health_checks(&self) -> Result<()>

Run periodic health checks

pub async fn start(&self) -> Result<()>

Start the cluster manager (health checks, discovery, etc.)

pub fn get_stats(&self) -> ClusterStats

Get cluster statistics

pub fn router(&self) -> Arc<ShardRouter>

Get the shard router

pub fn consensus(&self) -> Option<Arc<DagConsensus>>

Get the consensus engine