Struct DistributedOrchestrator

pub struct DistributedOrchestrator<W, C, Q, RIS, MS, ES, LS, WIS, CS>
where
    W: Workflow<C>,
    C: Context + Merge + Default,
    Q: WorkQueue<C, W::WorkItem> + Send + Sync,
    RIS: RunInfoStore + Send + Sync,
    MS: MetricsStore + Send + Sync,
    ES: ErrorStore + Send + Sync,
    LS: LivenessStore + Send + Sync,
    WIS: WorkItemStateStore<W::WorkItem> + Send + Sync,
    CS: ContextStore<C> + Send + Sync,
{ /* private fields */ }

Implementations

impl<W, C, Q, RIS, MS, ES, LS, WIS, CS> DistributedOrchestrator<W, C, Q, RIS, MS, ES, LS, WIS, CS>

where W: Workflow<C>, C: Context + Merge + Default, Q: WorkQueue<C, W::WorkItem> + Send + Sync, RIS: RunInfoStore + Send + Sync, MS: MetricsStore + Send + Sync, ES: ErrorStore + Send + Sync, LS: LivenessStore + Send + Sync, WIS: WorkItemStateStore<W::WorkItem> + Send + Sync, CS: ContextStore<C> + Send + Sync,

pub fn new( workflow: W, queue: Q, run_info_store: RIS, metrics_store: MS, error_store: ES, liveness_store: LS, work_item_state_store: WIS, context_store: CS, ) -> Self

Create a new orchestrator.

pub async fn start_run( &self, ctx: &WorkflowCtx<C>, input: W::Input, ) -> Result<String, FloxideError>

Start a new workflow run. Returns a run_id.

Note: Requires uuid crate in Cargo.toml: uuid = { version = “1”, features = [“v4”] }

pub async fn status(&self, run_id: &str) -> Result<RunStatus, FloxideError>

where C: Debug + Clone + Send + Sync,

Query the status of a run.

pub async fn list_runs( &self, filter: Option<RunStatus>, ) -> Result<Vec<RunInfo>, FloxideError>

where C: Debug + Clone + Send + Sync,

List all runs (optionally filter by status).

pub async fn cancel(&self, run_id: &str) -> Result<(), FloxideError>

where C: Debug + Clone + Send + Sync,

Cancel a run.

pub async fn pause(&self, run_id: &str) -> Result<(), FloxideError>

where C: Debug + Clone + Send + Sync,

Pause a run.

pub async fn resume(&self, run_id: &str) -> Result<(), FloxideError>

where C: Debug + Clone + Send + Sync,

Resume a run.

pub async fn errors( &self, run_id: &str, ) -> Result<Vec<WorkflowError>, FloxideError>

where C: Debug + Clone + Send + Sync,

Get all errors for a run.

pub async fn liveness(&self) -> Result<Vec<WorkerHealth>, FloxideError>

where C: Debug + Clone + Send + Sync,

pub async fn context(&self, run_id: &str) -> Result<C, FloxideError>

where C: Debug + Clone + Send + Sync,

pub async fn metrics(&self, run_id: &str) -> Result<RunMetrics, FloxideError>

where C: Debug + Clone + Send + Sync,

Get progress/metrics for a run.

pub async fn pending_work( &self, run_id: &str, ) -> Result<Vec<W::WorkItem>, FloxideError>

where C: Debug + Clone + Send + Sync,

Get pending work for a run.

pub async fn check_worker_liveness( &self, worker_ids: &[usize], threshold: Duration, ) -> Vec<(usize, LivenessStatus)>

Check liveness status of a list of workers.

pub async fn list_workers(&self) -> Result<Vec<usize>, LivenessStoreError>

List all known worker IDs.

pub async fn list_worker_health( &self, ) -> Result<Vec<WorkerHealth>, LivenessStoreError>

List all worker health info.

pub async fn list_work_items( &self, run_id: &str, ) -> Result<Vec<WorkItemState<W::WorkItem>>, WorkItemStateStoreError>

Get all work items for a run.

pub async fn complete_run(&self, run_id: &str) -> Result<(), FloxideError>

Mark a run as completed and set finished_at timestamp.

pub async fn wait_for_completion( &self, run_id: &str, poll_interval: Duration, ) -> Result<RunInfo, FloxideError>

Wait for a run to reach a terminal state (Completed, Failed, or Cancelled).