Struct NodeRegistry 

pub struct NodeRegistry { /* private fields */ }

Node registry for tracking cluster members

Implementations

impl NodeRegistry

pub fn new() -> Self

Create a new node registry

pub fn register_node(&mut self, nodeinfo: NodeInfo) -> CoreResult<bool>

Register a new node in the cluster Returns true if the node is new, false if it was already registered

pub fn get_all_nodes(&self) -> Vec<NodeInfo>

Get all registered nodes

pub fn get_healthy_nodes(&self) -> Vec<NodeInfo>

Get only healthy nodes

pub fn get_nodes_by_status(&self, status: NodeStatus) -> Vec<NodeInfo>

Get nodes with a specific status

pub fn get_node(&self, nodeid: &str) -> Option<&NodeInfo>

Get a specific node by ID

pub fn get_node_status(&self, nodeid: &str) -> Option<NodeStatus>

Get the status of a specific node

pub fn update_node_status( &mut self, nodeid: &str, status: NodeStatus, ) -> CoreResult<()>

Update the status of a specific node

pub fn remove_node(&mut self, nodeid: &str) -> Option<NodeInfo>

Remove a node from the registry

pub fn node_count(&self) -> usize

Get the total number of registered nodes

pub fn healthy_node_count(&self) -> usize

Get the number of healthy nodes

pub fn contains_node(&self, nodeid: &str) -> bool

Check if a node is registered

pub fn clear(&mut self)

Clear all nodes from the registry

pub fn get_stale_nodes(&self, max_age: Duration) -> Vec<NodeInfo>

Get nodes that haven’t been seen recently

pub fn update_node_last_seen(&mut self, nodeid: &str)

Update a node’s last seen timestamp

Trait Implementations

impl Debug for NodeRegistry

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

Formats the value using the given formatter.

impl Default for NodeRegistry

fn default() -> Self

Returns the “default value” for a type.