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

Sets the heartbeat timeout for regular wait_for and execute activities.

Zero selects the server default of one minute. Positive values must be whole seconds and at least the server-configured minimum, which defaults to ten seconds. Local activities ignore this option; an asynchronous fallback to a 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.

pub fn wait_for_load_attribute_map<T>( self, attribute_map: &AttributeMap<T>, ) -> Self

Loads every current instance of attribute_map for wait_for.

pub fn wait_for_load_attribute_map_instance( self, load: AttributeMapLoad, ) -> Self

Loads one AttributeMap instance for wait_for.

pub fn wait_for_load_channel<T>(self, channel: &Channel<T>) -> Self

Loads one Channel’s pending messages for wait_for.

pub fn wait_for_load_channel_map<T>(self, channel_map: &ChannelMap<T>) -> Self

Loads every current ChannelMap instance’s pending messages for wait_for.

pub fn wait_for_load_channel_map_instance(self, load: ChannelMapLoad) -> Self

Loads one ChannelMap instance’s pending messages for wait_for.

pub fn execute_load_attribute_map<T>( self, attribute_map: &AttributeMap<T>, ) -> Self

Loads every current instance of attribute_map for execute.

pub fn execute_load_attribute_map_instance(self, load: AttributeMapLoad) -> Self

Loads one AttributeMap instance for execute.

pub fn execute_load_channel<T>(self, channel: &Channel<T>) -> Self

Loads one Channel’s pending messages for execute.

pub fn execute_load_channel_map<T>(self, channel_map: &ChannelMap<T>) -> Self

Loads every current ChannelMap instance’s pending messages for execute.

pub fn execute_load_channel_map_instance(self, load: ChannelMapLoad) -> Self

Loads one ChannelMap instance’s pending messages for execute.

Trait Implementations

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

fn default() -> Self

Returns the “default value” for a type.