Struct NodeInfo 

pub struct NodeInfo {

    pub id: NodeId,
    pub hostname: String,
    pub ip_address: IpAddr,
    pub http_port: u16,
    pub grpc_port: u16,
    pub roles: Vec<NodeRole>,
    pub worker_capabilities: Vec<String>,
    pub status: NodeStatus,
    pub last_heartbeat: DateTime<Utc>,
    pub version: String,
    pub started_at: DateTime<Utc>,
    pub current_connections: u32,
    pub current_jobs: u32,
    pub cpu_usage: f32,
    pub memory_usage: f32,
}

Information about a node in the cluster.

Fields

id: NodeId

Unique node ID.

hostname: String

Hostname.

ip_address: IpAddr

IP address.

http_port: u16

HTTP port.

grpc_port: u16

gRPC port for inter-node communication.

roles: Vec<NodeRole>

Enabled roles.

worker_capabilities: Vec<String>

Worker capabilities.

status: NodeStatus

Current status.

last_heartbeat: DateTime<Utc>

Last heartbeat time.

version: String

Version string.

started_at: DateTime<Utc>

When the node started.

current_connections: u32

Current connection count.

current_jobs: u32

Current job count.

cpu_usage: f32

CPU usage percentage.

memory_usage: f32

Memory usage percentage.

Implementations

impl NodeInfo

pub fn new_local( hostname: String, ip_address: IpAddr, http_port: u16, grpc_port: u16, roles: Vec<NodeRole>, worker_capabilities: Vec<String>, version: String, ) -> Self

Create a new node info for the local node.

pub fn has_role(&self, role: NodeRole) -> bool

Check if this node has a specific role.

pub fn has_capability(&self, capability: &str) -> bool

Check if this node has a specific worker capability.

pub fn load(&self) -> f32

Calculate node load (0.0 to 1.0).

Trait Implementations

impl Clone for NodeInfo

fn clone(&self) -> NodeInfo

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for NodeInfo

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

Formats the value using the given formatter.