Struct Workflow 

pub struct Workflow { /* private fields */ }

Validated, immutable workflow definition.

Implementations

impl Workflow

pub fn run<'a>( &'a self, input: impl Into<Value> + Send + 'a, run: &'a RunContext, ) -> WorkflowFuture<'a, Result<WorkflowOutcome, WorkflowError>>

Executes this workflow from the first node.

pub fn run_checkpointed<'a>( &'a self, input: impl Into<Value> + Send + 'a, run: &'a RunContext, checkpoint: &'a WorkflowCheckpoint, ) -> WorkflowFuture<'a, Result<WorkflowOutcome, WorkflowError>>

Executes with write-ahead workflow checkpoint persistence.

pub fn resume<'a>( &'a self, checkpoint: &'a WorkflowCheckpoint, run: &'a RunContext, policy: WorkflowResumePolicy, ) -> WorkflowFuture<'a, Result<WorkflowOutcome, WorkflowError>>

Resumes a persisted workflow execution.

impl Workflow

pub fn builder(name: impl Into<String>) -> WorkflowBuilder

Starts a fluent workflow definition.

pub fn name(&self) -> &str

Returns the stable workflow name.

pub const fn version(&self) -> u32

Returns the definition version used to validate checkpoints.

pub fn step_ids(&self) -> impl ExactSizeIterator<Item = &StepId>

Returns stable node identifiers in execution order.

Trait Implementations

impl Clone for Workflow

fn clone(&self) -> Workflow

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for Workflow

fn fmt(&self, formatter: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.