Struct WorkflowCoordinator

pub struct WorkflowCoordinator { /* private fields */ }

Workflow coordinator manages distributed workflow execution

Implementations

impl WorkflowCoordinator

pub fn new( local_peer_id: String, endpoint: Arc<NatTraversalEndpoint>, capabilities: NodeCapabilities, ) -> Self

Create a new workflow coordinator

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

Start the coordinator

pub async fn coordinate_workflow( &self, workflow_id: WorkflowId, participants: Vec<String>, stage_assignments: HashMap<StageId, String>, coordination_timeout: Duration, ) -> Result<WorkflowCoordinationResult, WorkflowError>

Coordinate a workflow execution

pub async fn join_workflow( &self, workflow_id: WorkflowId, coordinator: String, ) -> Result<(), WorkflowError>

Join a coordinated workflow as a participant

pub async fn update_stage_status( &self, workflow_id: WorkflowId, stage_id: StageId, status: StageStatus, metrics: StageMetrics, ) -> Result<(), WorkflowError>

Update stage status

pub async fn signal_barrier_ready( &self, workflow_id: WorkflowId, barrier_id: String, ) -> Result<(), WorkflowError>

Signal barrier readiness

Trait Implementations

impl Clone for WorkflowCoordinator

fn clone(&self) -> Self

Returns a duplicate of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.