Struct WorkflowEngine 

pub struct WorkflowEngine { /* private fields */ }

Thread-safe workflow engine that stores definitions and runs.

Implementations

impl WorkflowEngine

pub fn new() -> Self

Create a new, empty workflow engine.

pub async fn register_workflow(&self, workflow: WorkflowDefinition)

Register a workflow definition. Overwrites if id already exists.

pub async fn get_workflow( &self, workflow_id: &str, ) -> Option<WorkflowDefinition>

Get a registered workflow definition by id.

pub async fn start( &self, workflow_id: &str, trigger_data: Value, ) -> Option<String>

Start a new run of the given workflow. Returns the run_id.

Returns None if the workflow id is not registered.

pub async fn advance(&self, run_id: &str) -> Result<bool, String>

Advance a run to the next step. Evaluates the step condition, executes a simulated step, records the result, and moves the index forward.

Returns Ok(true) if the step was advanced, Ok(false) if the run is already completed/failed/timed-out, and Err on unknown run id.

pub async fn get_run(&self, run_id: &str) -> Option<WorkflowRun>

Retrieve the current state of a run.

pub async fn list_runs(&self, workflow_id: &str) -> Vec<WorkflowRun>

List all runs for a given workflow id.

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

Pause a running workflow run.

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

Resume a paused workflow run.

pub async fn run_to_completion( &self, run_id: &str, ) -> Result<WorkflowRun, String>

Run a workflow to completion (advance until done). Returns the final run state.

Applies an internal safety limit of 1000 iterations.

Trait Implementations

impl Clone for WorkflowEngine

fn clone(&self) -> WorkflowEngine

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Default for WorkflowEngine

fn default() -> Self

Returns the “default value” for a type.