Struct ClusterManager 

pub struct ClusterManager {
    pub config: ClusterConfig,
    pub active_nodes: HashMap<String, ClusterNode>,
    pub node_statistics: HashMap<String, NodeStatistics>,
}

Cluster manager for node coordination

Fields

config: ClusterConfig

Cluster configuration

active_nodes: HashMap<String, ClusterNode>

Active nodes

node_statistics: HashMap<String, NodeStatistics>

Node statistics

Implementations

impl ClusterManager

pub fn new() -> Self

Create a new cluster manager

pub fn add_node(&mut self, address: String, resources: NodeResources)

Add a node to the cluster

pub fn remove_node(&mut self, address: &str) -> Option<ClusterNode>

Remove a node from the cluster

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

Get available nodes

pub fn update_node_status(&mut self, address: &str, status: NodeStatus)

Update node status

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

Get node by address

Trait Implementations

impl Debug for ClusterManager

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.

impl Default for ClusterManager

fn default() -> Self

Returns the “default value” for a type.