Struct ClusterState 

pub struct ClusterState { /* private fields */ }

Cluster state with thread-safe metrics collection

Implementations

impl ClusterState

pub fn new() -> Self

Create new cluster state

pub fn circuit_breaker_for(&self, node_id: &str) -> CircuitBreaker

Gets (creating with default config on first use) the circuit breaker tracking TCP transport failures for one node. The returned handle is a cheap Arc-backed clone sharing state with every other caller for the same node_id — recording a failure through one clone is visible to all of them.

pub fn register(&self, node: NodeResources)

Register a new node with the cluster

pub fn register_with_addr(&self, node: NodeResources, addr: Option<SocketAddr>)

Register a new node with a specific socket address

pub fn nodes(&self) -> Vec<NodeResources>

Get all nodes

pub fn node_count(&self) -> usize

Get total number of registered nodes.

pub fn nodes_snapshot(&self) -> Arc<Vec<NodeResources>>

Get a shared snapshot of all nodes

pub fn with_metrics<F, R>(&self, f: F) -> R

where F: FnOnce(&HashMap<String, NodeMetrics>) -> R,

Execute a closure with a read lock on the metrics map, avoiding clones and multiple acquisitions.

pub fn get_metrics(&self, node_id: &str) -> Option<NodeMetrics>

Get metrics for a specific node

pub fn update_heartbeat(&self, node_id: &str)

Update last heartbeat for a node

pub fn get_metrics_mut<F, R>(&self, node_id: &str, f: F) -> Option<R>

where F: FnOnce(&mut NodeMetrics) -> R,

Get metrics mutable reference (for internal updates)

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

Check if a node has timed out

pub fn mark_failed(&self, node_id: &str)

Mark a node as failed due to timeout

pub fn recover_node(&self, node_id: &str)

Recover a failed node

pub fn active_nodes(&self) -> Vec<NodeMetrics>

Get all active nodes

pub fn active_nodes_count(&self) -> usize

Get the count of active nodes without cloning metrics

pub fn total_vram_gb(&self) -> f32

Get total cluster VRAM

pub fn total_system_memory_gb(&self) -> f32

Get total system memory

Trait Implementations

impl Clone for ClusterState

fn clone(&self) -> Self

Returns a duplicate of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.

impl Debug for ClusterState

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

Formats the value using the given formatter.

impl Default for ClusterState

fn default() -> Self

Returns the “default value” for a type.