Struct Coordinator 

pub struct Coordinator { /* private fields */ }

Coordinator for distributed task execution.

Implementations

impl Coordinator

pub fn new(config: CoordinatorConfig) -> Self

Create a new coordinator.

pub fn add_worker(&self, worker_id: String, address: String) -> Result<()>

Add a worker to the coordinator.

pub fn remove_worker(&self, worker_id: &str) -> Result<()>

Remove a worker from the coordinator.

pub fn update_worker_heartbeat(&self, worker_id: &str) -> Result<()>

Update worker heartbeat.

pub fn check_worker_timeouts(&self) -> Result<Vec<String>>

Check for timed-out workers and reassign their tasks.

pub fn submit_task( &self, partition_id: PartitionId, operation: TaskOperation, ) -> Result<TaskId>

Submit a task for execution.

pub fn next_task(&self) -> Result<Option<Task>>

Get the next task to execute.

pub fn assign_task(&self, task: Task, worker_id: String) -> Result<()>

Assign a task to a worker.

pub fn complete_task(&self, task_id: TaskId, result: TaskResult) -> Result<()>

Record task completion.

pub fn get_available_worker(&self) -> Result<Option<String>>

Get the best available worker for a task.

pub fn get_progress(&self) -> Result<CoordinatorProgress>

Get execution progress.

pub fn collect_results(&self) -> Result<Vec<TaskResult>>

Collect all task results.

pub fn is_complete(&self) -> bool

Check if all tasks are complete.

pub fn list_workers(&self) -> Result<Vec<WorkerInfo>>

Get list of all workers.

pub async fn start_monitoring( self: Arc<Self>, shutdown_rx: Receiver<()>, ) -> Result<()>

Start monitoring loop for worker health.