Struct DistributedCoordinator 

pub struct DistributedCoordinator { /* private fields */ }

Distributed coordinator

Implementations

impl DistributedCoordinator

pub fn new(node_id: impl Into<String>) -> Self

Create a new distributed coordinator

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

Start the coordinator

pub async fn register_node(&self, node: Node) -> Result<(), String>

Register a node

pub async fn unregister_node(&self, node_id: &str) -> Result<(), String>

Unregister a node

pub async fn submit_task(&self, task: DistributedTask) -> Result<(), String>

Submit a distributed task

pub async fn heartbeat(&self) -> Result<(), String>

Send heartbeat

pub async fn trigger_election(&self) -> Result<(), String>

Trigger leader election

pub fn get_leader(&self) -> Option<String>

Get current leader

pub fn is_leader(&self) -> bool

Check if this node is the leader

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

Get all registered nodes

pub fn get_active_nodes(&self) -> Vec<Node>

Get active nodes

pub fn get_task(&self, task_id: &str) -> Option<DistributedTask>

Get task status

pub fn get_tasks(&self) -> Vec<DistributedTask>

Get all tasks

pub fn get_task_execution_states( &self, task_id: &str, ) -> Vec<NodeExecutionState>

Get node execution states for a task