Struct OrchestratorNode 

pub struct OrchestratorNode {
    pub nodeid: String,
    pub address: SocketAddr,
    pub capacity: usize,
    pub current_load: usize,
    pub capabilities: Vec<String>,
    pub last_heartbeat: Instant,
}

Node information for orchestration

Fields

nodeid: String

address: SocketAddr

capacity: usize

current_load: usize

capabilities: Vec<String>

last_heartbeat: Instant

Implementations

impl OrchestratorNode

pub fn id(nodeid: String, address: SocketAddr, capacity: usize) -> Self

Create a new orchestrator node

pub fn new(nodeid: String, address: SocketAddr, capacity: usize) -> Self

Create a new orchestrator node (alias for id)

pub fn can_accept_task(&self) -> bool

Check if node can accept more tasks

pub fn update_heartbeat(&mut self)

Update node heartbeat

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

Check if node is responsive

Trait Implementations

impl Clone for OrchestratorNode

fn clone(&self) -> OrchestratorNode

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for OrchestratorNode

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

Formats the value using the given formatter.