Struct StartFlowOptions 

pub struct StartFlowOptions { /* private fields */ }

Configures a new Flow execution.

All optional fields are absent by default. Initial Attribute values are encoded when the start request is sent. Use a stable request ID to make retries of the same logical request idempotent.

Examples

use dex_sdk::{Attribute, IdReusePolicy, StartFlowOptions};
use std::time::Duration;

let customer = Attribute::<String>::new("customer");
let options = StartFlowOptions::new()
    .timeout(Duration::from_secs(3_600))
    .id_reuse_policy(IdReusePolicy::AllowIfNotRunning)
    .initial_attribute(&customer, "customer-42".to_owned())
    .request_id("create-order-42");

Implementations

impl StartFlowOptions

pub fn new() -> Self

Creates start options that preserve all server defaults.

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

Sets Dex’s durable soft timeout. A zero duration disables it.

pub fn timeout_policy(self, value: FlowTimeoutPolicy) -> Self

Sets the action taken when the positive Flow timeout expires.

Handler is rejected before start when the registered Flow has no timeout handler.

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

Delays the first Step after the server accepts the Flow.

pub fn id_reuse_policy(self, value: IdReusePolicy) -> Self

Sets how the server handles an existing Flow with the same ID.

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

Sets the whole-Flow retry policy after a terminal failure.

pub fn initial_attribute<T: Value>( self, attribute: &Attribute<T>, value: T, ) -> Self

Adds an initial value for a declared Attribute.

pub fn initial_attribute_map<T: Value>( self, attribute: &AttributeMap<T>, instance: &str, value: T, ) -> Self

Adds an initial value for one Attribute-map instance.

pub fn config_override(self, value: FlowConfig) -> Self

Overrides the registered Flow configuration for this execution.

pub fn ignore_already_started(self, value: bool) -> Self

Returns the existing run ID instead of an error when the Flow already exists.

pub fn request_id(self, value: impl Into<String>) -> Self

Sets the idempotency key for this start request.

Trait Implementations

impl Clone for StartFlowOptions

fn clone(&self) -> StartFlowOptions

Returns a duplicate of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.

impl Default for StartFlowOptions

fn default() -> Self

Returns the “default value” for a type.