Struct DistributedCluster 

pub struct DistributedCluster { /* private fields */ }

Distributed computing cluster manager

Implementations

impl DistributedCluster

pub fn new(config: ClusterConfig) -> Self

Create new distributed cluster

pub fn register_node(&self, node: ClusterNode) -> Result<(), DistributedError>

Register a node in the cluster

pub fn remove_node(&self, node_id: &str) -> Result<(), DistributedError>

Remove a node from the cluster

pub fn get_nodes(&self) -> Vec<ClusterNode>

Get all nodes in the cluster

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

Get available nodes

pub fn submit_job( &self, job: DistributedJob, ) -> Result<String, DistributedError>

Submit a job to the cluster

pub fn schedule_jobs(&self) -> Result<(), DistributedError>

Schedule jobs in the queue

pub fn get_job_status(&self, job_id: &str) -> Option<JobStatus>

Get job status

pub fn get_job_execution(&self, job_id: &str) -> Option<JobExecution>

Get job execution info

pub fn cancel_job(&self, job_id: &str) -> Result<(), DistributedError>

Cancel a job

pub fn update_heartbeat( &self, node_id: &str, load_metrics: LoadMetrics, ) -> Result<(), DistributedError>

Update node heartbeat

pub fn get_cluster_stats(&self) -> ClusterStats

Get cluster statistics

pub fn start_monitoring(&self) -> Result<(), DistributedError>

Start cluster monitoring

pub fn rebalance_workload(&self) -> Result<(), DistributedError>

Rebalance workload across nodes

pub fn handle_node_failure(&self, node_id: &str) -> Result<(), DistributedError>

Handle node failure