Struct NodeManager 

pub struct NodeManager { /* private fields */ }

Manager for compute nodes in the distributed system

Implementations

impl NodeManager

pub fn new(health_check_timeout: Duration) -> Self

Create a new node manager

pub fn start_health_monitoring(&self) -> IntegrateResult<()>

Start the health monitoring background thread

pub fn stop_health_monitoring(&self)

Stop health monitoring

pub fn register_node( &self, address: SocketAddr, capabilities: NodeCapabilities, ) -> DistributedResult<NodeId>

Register a new node

pub fn deregister_node(&self, node_id: NodeId) -> DistributedResult<()>

Deregister a node

pub fn update_heartbeat(&self, node_id: NodeId) -> DistributedResult<()>

Update node heartbeat

pub fn update_status( &self, node_id: NodeId, status: NodeStatus, ) -> DistributedResult<()>

Update node status

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

Get list of available nodes

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

Get all registered nodes

pub fn get_node(&self, node_id: NodeId) -> Option<NodeInfo>

Get node by ID

pub fn available_node_count(&self) -> usize

Get number of available nodes

pub fn on_node_failure<F>(&self, callback: F)

where F: Fn(NodeId) + Send + Sync + 'static,

Register a failure callback

pub fn record_job_completion( &self, node_id: NodeId, duration: Duration, ) -> DistributedResult<()>

Record job completion for a node

pub fn select_best_node(&self, estimated_cost: f64) -> Option<NodeId>

Select best node for a given workload

Trait Implementations

impl Drop for NodeManager

fn drop(&mut self)

Executes the destructor for this type.