Struct Cluster 

pub struct Cluster {
    pub task_graph: Arc<TaskGraph>,
    pub worker_pool: Arc<WorkerPool>,
    pub scheduler: Arc<Scheduler>,
    pub coordinator: Arc<ClusterCoordinator>,
    pub fault_tolerance: Arc<FaultToleranceManager>,
    pub locality_optimizer: Arc<DataLocalityOptimizer>,
    pub cache: Arc<DistributedCache>,
    pub replication: Arc<ReplicationManager>,
    pub metrics: Arc<ClusterMetrics>,
}

Complete cluster instance.

The Cluster struct provides access to all cluster components including the task graph, worker pool, scheduler, coordinator, fault tolerance, data locality optimizer, distributed cache, and replication manager.

Examples

use oxigdal_cluster::Cluster;

#[tokio::main]
async fn main() -> oxigdal_cluster::Result<()> {
    // Create and start a cluster
    let cluster = Cluster::new();
    cluster.start().await?;

    // Access cluster components
    let metrics = cluster.metrics.snapshot();
    println!("Tasks completed: {}", metrics.tasks_completed);

    // Get cluster statistics
    let stats = cluster.get_statistics();
    println!("Total workers: {}", stats.worker_pool.total_workers);

    // Stop the cluster
    cluster.stop().await?;
    Ok(())
}

Fields

task_graph: Arc<TaskGraph>

Task graph

worker_pool: Arc<WorkerPool>

Worker pool

scheduler: Arc<Scheduler>

Scheduler

coordinator: Arc<ClusterCoordinator>

Coordinator

fault_tolerance: Arc<FaultToleranceManager>

Fault tolerance manager

locality_optimizer: Arc<DataLocalityOptimizer>

Data locality optimizer

cache: Arc<DistributedCache>

Distributed cache

replication: Arc<ReplicationManager>

Replication manager

metrics: Arc<ClusterMetrics>

Cluster metrics

Implementations

impl Cluster

pub fn new() -> Self

Create a new cluster with default configuration.

pub async fn start(&self) -> Result<()>

Start all cluster components.

pub async fn stop(&self) -> Result<()>

Stop all cluster components.

pub fn get_statistics(&self) -> ClusterStatistics

Get cluster-wide statistics.

Trait Implementations

impl Default for Cluster

fn default() -> Self

Returns the “default value” for a type.