Struct ClusterNode 

pub struct ClusterNode {
    pub node_id: String,
    pub address: SocketAddr,
    pub status: NodeStatus,
    pub last_seen: DateTime<Utc>,
    pub metadata: HashMap<String, String>,
    pub capacity: f64,
}

Information about a cluster node

Fields

node_id: String

Unique node identifier

address: SocketAddr

Network address of the node

status: NodeStatus

Current status of the node

last_seen: DateTime<Utc>

Last time the node was seen alive

metadata: HashMap<String, String>

Metadata about the node

capacity: f64

Node capacity (for load balancing)

Implementations

impl ClusterNode

pub fn new(node_id: String, address: SocketAddr) -> Self

Create a new cluster node

pub fn is_healthy(&self, timeout: Duration) -> bool

Check if the node is healthy (seen recently)

pub fn heartbeat(&mut self)

Update the last seen timestamp

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.

impl Debug for ClusterNode

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

Formats the value using the given formatter.

impl<'de> Deserialize<'de> for ClusterNode

fn deserialize<__D>(__deserializer: __D) -> Result<Self, __D::Error>

where __D: Deserializer<'de>,

Deserialize this value from the given Serde deserializer.

impl Serialize for ClusterNode

fn serialize<__S>(&self, __serializer: __S) -> Result<__S::Ok, __S::Error>

where __S: Serializer,

Serialize this value into the given Serde serializer.