Struct StepBuilder 

pub struct StepBuilder<D: WorkflowData> { /* private fields */ }

Builder for configuring a single step in the workflow.

Owns the WorkflowBuilder, consuming self on each method call. This avoids all lifetime/borrow issues.

Implementations

impl<D: WorkflowData> StepBuilder<D>

pub fn name(self, name: &str) -> Self

Set the display name of the current step.

pub fn id(self, external_id: &str) -> Self

Set an external ID for forward references.

pub fn on_error(self, behavior: ErrorBehavior) -> Self

Set the error handling behavior for this step.

pub fn config(self, config: Value) -> Self

Attach arbitrary JSON configuration to this step.

The step can read it at runtime via context.step.step_config.

pub fn compensate_with<C: StepBody + Default + 'static>(self) -> Self

Add a compensation step for saga rollback.

pub fn then<S: StepBody + Default + 'static>(self) -> StepBuilder<D>

Chain the next step. Wires an outcome from the current step to the new one.

pub fn then_fn( self, f: impl Fn() -> ExecutionResult + Send + Sync + 'static, ) -> StepBuilder<D>

Chain an inline function step.

pub fn wait_for(self, event_name: &str, event_key: &str) -> StepBuilder<D>

Insert a WaitFor step.

pub fn delay(self, duration: Duration) -> StepBuilder<D>

Insert a Delay step.

pub fn if_do<S: StepBody + Default + 'static>( self, build_children: impl FnOnce(&mut WorkflowBuilder<D>), ) -> StepBuilder<D>

Insert an If container step with child steps built by the closure. The type parameter S is the step type used for the If condition evaluation.

pub fn while_do<S: StepBody + Default + 'static>( self, build_children: impl FnOnce(&mut WorkflowBuilder<D>), ) -> StepBuilder<D>

Insert a While container step.

pub fn for_each<S: StepBody + Default + 'static>( self, build_children: impl FnOnce(&mut WorkflowBuilder<D>), ) -> StepBuilder<D>

Insert a ForEach container step.

pub fn saga( self, build_children: impl FnOnce(&mut WorkflowBuilder<D>), ) -> StepBuilder<D>

Insert a Saga container step with child steps.

pub fn parallel( self, build_branches: impl FnOnce(ParallelBuilder<D>) -> ParallelBuilder<D>, ) -> StepBuilder<D>

Start a parallel block.

pub fn end_workflow(self) -> WorkflowBuilder<D>

Mark this step as the terminal step (no further outcomes).

pub fn build(self, id: impl Into<String>, version: u32) -> WorkflowDefinition

Access the compiled definition directly (shortcut for end_workflow().build()).