Struct StepBuilder 

pub struct StepBuilder<'a, T, F, C>
where
    T: Serialize + DeserializeOwned + Send + 'static,
    F: Future<Output = Result<T>> + Send + 'a,
    C: Future<Output = Result<()>> + Send + 'a,
{ /* private fields */ }

Builder for configuring and executing a step.

Implementations

impl<'a, T, F, C> StepBuilder<'a, T, F, C>

where T: Serialize + DeserializeOwned + Send + Clone + 'static, F: Future<Output = Result<T>> + Send + 'a, C: Future<Output = Result<()>> + Send + 'a,

pub fn new(name: impl Into<String>) -> Self

Create a new step builder.

pub fn run<RF>(self, f: RF) -> Self

where RF: FnOnce() -> F + Send + 'a,

Set the step execution function.

pub fn compensate<CF>(self, f: CF) -> Self

where CF: Fn(T) -> Pin<Box<C>> + Send + Sync + 'a,

Set the compensation function.

pub fn timeout(self, duration: Duration) -> Self

Set step timeout.

pub fn retry(self, count: u32, delay: Duration) -> Self

Configure retry behavior.

pub fn optional(self) -> Self

Mark the step as optional (failure won’t trigger compensation).

pub fn name(&self) -> &str

Get step name.

pub fn is_optional(&self) -> bool

Check if step is optional.

pub fn retry_count(&self) -> u32

Get retry count.

pub fn retry_delay(&self) -> Duration

Get retry delay.

pub fn get_timeout(&self) -> Option<Duration>

Get timeout.