Struct NodeRegistry 

pub struct NodeRegistry { /* private fields */ }

Central registry of all cluster nodes.

Supports fast lookup by ID and filtered queries by role/status/tag.

Implementations

impl NodeRegistry

pub fn new() -> Self

Create an empty registry.

pub fn register(&mut self, node: NodeInfo)

Register a new node. If a node with the same ID already exists, it is replaced.

pub fn deregister(&mut self, id: &str) -> Option<NodeInfo>

Remove a node by ID, returning it if found.

pub fn get(&self, id: &str) -> Option<&NodeInfo>

Look up a node by ID.

pub fn get_mut(&mut self, id: &str) -> Option<&mut NodeInfo>

Mutable access to a node by ID.

pub fn len(&self) -> usize

Total number of registered nodes.

pub fn is_empty(&self) -> bool

Returns true if the registry has no nodes.

pub fn by_role(&self, role: NodeRole) -> Vec<&NodeInfo>

All nodes with a given role.

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

All nodes with a given status.

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

All available (Healthy or Degraded) worker nodes.

pub fn by_tag(&self, tag: &str) -> Vec<&NodeInfo>

All nodes that have a specific tag.

pub fn remove_node(&mut self, id: &str, now_ms: u64)

Mark a node as removed (soft delete).

pub fn evict_stale(&mut self, now_ms: u64, ttl_ms: u64) -> Vec<String>

Evict nodes that have not been seen within ttl_ms of now_ms.

Returns the IDs of evicted nodes.

pub fn status_summary(&self) -> (usize, usize, usize, usize, usize)

Summary counts: (total, healthy, degraded, suspended, removed).

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() -> NodeRegistry

Returns the “default value” for a type.