Struct ClusterNode 

pub struct ClusterNode { /* private fields */ }

Manages cluster membership and leader election via etcd.

Each worker process creates one ClusterNode instance that:

• Registers the worker in the cluster node registry
• Participates in leader election
• Maintains health status via lease keep-alive

Implementations

impl ClusterNode

pub fn new( etcd_endpoints: Vec<String>, node_id: String, node_ip: IpAddr, group_name: String, ttl: Option<i64>, ) -> Self

Creates a new ClusterNode.

Arguments

• etcd_endpoints - List of etcd endpoints (e.g., ["http://localhost:2379"])
• node_id - Unique identifier for this node
• node_ip - IP address of this node (used for service discovery)
• group_name - Logical group name for cluster membership
• ttl - Lease TTL in seconds (default: 5)

Panics

Panics if etcd_endpoints is empty or contains invalid URLs.

pub fn current_health(&self) -> HealthStatus

Returns the current health status of the node’s etcd connection.

pub fn is_leader(&self) -> bool

Returns true if this node is currently the leader.

pub async fn run(&self, shutdown: &mut Receiver<()>) -> Result<(), ClusterError>

Starts the node’s main loop.

This method runs indefinitely, maintaining cluster membership and participating in leader election. It automatically reconnects on connection failures.

If a metrics collector and update interval are configured, a background task will periodically update the node’s metrics in etcd.

Arguments

• shutdown - Shutdown signal receiver. When a message is received, the node will gracefully resign leadership and exit.

Returns

Returns Ok(()) on graceful shutdown, Err if unable to connect to etcd.

pub async fn leave( &self, client: &mut Client, lease_id: i64, ) -> Result<(), ClusterError>

Removes this node from the cluster registry.

pub async fn resign( &self, client: &mut Client, leader: LeaderKey, ) -> Result<(), ClusterError>

Resigns from leadership.

Trait Implementations

impl Clone for ClusterNode

fn clone(&self) -> ClusterNode

Returns a duplicate of the value.

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

Performs copy-assignment from source.