Struct WorkflowBuilder 

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

Fluent builder for constructing workflow definitions.

Uses an owned-self pattern: each method consumes and returns the builder, avoiding lifetime issues with mutable borrows.

Example

let def = WorkflowBuilder::<MyData>::new()
    .start_with::<StepA>()
    .name("Step A")
    .then::<StepB>()
    .name("Step B")
    .end_workflow()
    .build("my-workflow", 1);

Implementations

impl<D: WorkflowData> WorkflowBuilder<D>

pub fn new() -> Self

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

Add the first step of the workflow.

pub fn add_step(&mut self, step_type: &str) -> usize

Add a step by type name. Used by container builder closures.

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

Compile the builder into a WorkflowDefinition.

pub fn build_with_closures( self, id: impl Into<String>, version: u32, ) -> (WorkflowDefinition, HashMap<usize, Box<dyn Fn() -> ExecutionResult + Send + Sync>>)

Compile the builder into a WorkflowDefinition and return any inline closures keyed by step id.

pub fn register_inline_steps( self, registry: &mut StepRegistry, id: impl Into<String>, version: u32, ) -> WorkflowDefinition

Register all inline closures from this builder into the given step registry.

Each inline closure is registered under a unique key derived from the InlineStep type name and step id.

Trait Implementations

impl<D: WorkflowData> Default for WorkflowBuilder<D>

fn default() -> Self

Returns the “default value” for a type.