Struct WorkflowEngine

pub struct WorkflowEngine { /* private fields */ }

Workflow execution engine

Implementations

impl WorkflowEngine

pub fn new( config: WorkflowEngineConfig, registry: Arc<WorkflowRegistry>, state_store: Arc<dyn StateStore>, ) -> Self

Create a new workflow engine

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

Start the workflow engine

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

Stop the workflow engine

pub async fn start_workflow( &self, workflow_id: &str, version: &Version, input: HashMap<String, Vec<u8>>, ) -> Result<WorkflowHandle, WorkflowError>

Start a new workflow

pub async fn resume_workflow( &self, instance_id: WorkflowId, ) -> Result<WorkflowHandle, WorkflowError>

Resume a workflow from saved state

Trait Implementations

impl Clone for WorkflowEngine

fn clone(&self) -> Self

Returns a duplicate of the value.

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

Performs copy-assignment from source.