Struct WorkflowEngine 

pub struct WorkflowEngine { /* private fields */ }

Workflow engine for orchestrating executions.

Implementations

impl WorkflowEngine

pub fn new() -> Self

Create a new workflow engine.

pub fn register_workflow(&self, workflow: Workflow) -> Result<WorkflowId>

Register a workflow definition.

pub fn register_template(&self, template: WorkflowTemplate) -> Result<()>

Register a workflow template.

pub fn create_from_template( &self, template_name: &str, parameters: HashMap<String, Value>, ) -> Result<Workflow>

Create workflow from template.

pub fn start_execution(&self, workflow_id: WorkflowId) -> Result<Uuid>

Start a workflow execution.

pub fn pause_execution(&self, execution_id: Uuid) -> Result<()>

Pause a workflow execution.

pub fn resume_execution(&self, execution_id: Uuid) -> Result<()>

Resume a paused workflow execution.

pub fn cancel_execution(&self, execution_id: Uuid) -> Result<()>

Cancel a workflow execution.

pub fn complete_step(&self, execution_id: Uuid, step_id: String) -> Result<()>

Complete a workflow step.

pub fn fail_step( &self, execution_id: Uuid, step_id: String, error: String, ) -> Result<()>

Fail a workflow step.

pub fn get_execution(&self, execution_id: Uuid) -> Option<WorkflowExecution>

Get workflow execution status.

pub fn list_executions(&self, workflow_id: WorkflowId) -> Vec<WorkflowExecution>

List all executions for a workflow.

pub fn list_running_executions(&self) -> Vec<WorkflowExecution>

List running executions.

pub fn get_stats(&self) -> WorkflowStats

Get workflow statistics.

Trait Implementations

impl Default for WorkflowEngine

fn default() -> Self

Returns the “default value” for a type.