Struct StepOptions 

pub struct StepOptions<Input> { /* private fields */ }

Configures one Step’s handler execution and persistence behavior.

New options preserve server timeout, retry, and durability defaults. wait_for failures fail the Flow by default. Attribute locks apply only to the matching handler call. The type system checks that an execute-failure recovery Step accepts the same input type.

Examples

use dex_sdk::{Attribute, RetryPolicy, StepOptions, WaitForFailurePolicy};
use std::time::Duration;

let balance = Attribute::<i64>::new("balance");
let options = StepOptions::<String>::new()
    .execute_method_timeout(Duration::from_secs(30))
    .execute_retry(RetryPolicy::new().maximum_attempts(3))
    .wait_for_failure(WaitForFailurePolicy::Proceed)
    .execute_lock(balance.lock());

Implementations

impl<Input: Value> StepOptions<Input>

pub fn new() -> Self

Creates options that preserve server defaults and fail on exhausted wait_for retries.

pub fn wait_for_method_timeout(self, value: Duration) -> Self

Sets the maximum duration of one wait_for handler attempt.

pub fn execute_method_timeout(self, value: Duration) -> Self

Sets the maximum duration of one execute handler attempt.

pub fn heartbeat_timeout(self, value: Duration) -> Self

Enables cooperative cancellation heartbeats for regular wait_for and execute activities.

Zero disables heartbeats. Positive values must be whole seconds within the int32 range. Local activities ignore this option; an asynchronous fallback to regular activity uses it.

pub fn wait_for_retry(self, value: RetryPolicy) -> Self

Sets the retry policy for failed wait_for attempts.

pub fn execute_retry(self, value: RetryPolicy) -> Self

Sets the retry policy for failed execute attempts.

pub fn wait_for_failure(self, value: WaitForFailurePolicy) -> Self

Selects whether exhausted wait_for retries fail or advance the Flow.

pub fn on_execute_failure_proceed_to<RecoveryStep>( self, step: &RecoveryStep, ) -> Self

where RecoveryStep: Step<Input = Input>,

Routes exhausted execute failures to a recovery Step with the same input type.

pub fn wait_for_durability(self, value: StepDurability) -> Self

Overrides persistence durability for writes staged by wait_for.

pub fn execute_durability(self, value: StepDurability) -> Self

Overrides persistence durability for writes staged by execute.

pub fn wait_for_lock(self, value: AttributeLock) -> Self

Adds an Attribute lock held for the wait_for invocation.

pub fn execute_lock(self, value: AttributeLock) -> Self

Adds an Attribute lock held for the execute invocation.

Trait Implementations

impl<Input: Value> Default for StepOptions<Input>

fn default() -> Self

Returns the “default value” for a type.