Struct FlowBuilder

pub struct FlowBuilder { /* private fields */ }

Builder for creating flows with a fluent API

Implementations

impl FlowBuilder

pub fn new() -> Self

Creates a new FlowBuilder

pub fn step<Fut, F>(self, f: F) -> Self

where F: FnMut(SharedContext) -> Fut + Send + 'static, Fut: Future<Output = Result<()>> + Send + 'static,

Adds a simple step to the flow

pub fn named_step<Fut, F>(self, name: &'static str, f: F) -> Self

where F: FnMut(SharedContext) -> Fut + Send + 'static, Fut: Future<Output = Result<()>> + Send + 'static,

Adds a named step to the flow with automatic logging

pub fn step_if<Fut, F, Cond>(self, cond: Cond, f: F) -> Self

where Cond: Fn(&FlowContext) -> bool + Send + Sync + 'static, F: FnMut(SharedContext) -> Fut + Send + 'static, Fut: Future<Output = Result<()>> + Send + 'static,

Adds a conditional step that only executes if the condition is met

pub fn wait_until<Cond>( self, cond: Cond, interval: Duration, max_retry: usize, ) -> Self

where Cond: Fn(&FlowContext) -> bool + Send + Sync + 'static,

Adds a wait step that waits until a condition is met

pub fn build(self) -> Flow

Builds the flow

pub fn into_steps(self) -> Vec<Step>

Access steps for runtime extensions

pub async fn execute(self) -> Result<FlowContext>

Builds and executes the flow immediately

pub async fn execute_with_context( self, context: FlowContext, ) -> Result<FlowContext>

Builds and executes the flow with a custom context

Trait Implementations

impl Default for FlowBuilder

fn default() -> Self

Returns the “default value” for a type.