Struct FlowSettings 

pub struct FlowSettings {
    pub max_concurrent_executions: u32,
    pub execution_timeout_ms: u64,
    pub circuit_breaker_threshold: f64,
    pub circuit_breaker_window_ms: u64,
    pub max_concurrent_versions: u32,
    pub drain_timeout_ms: u64,
    pub drain_grace_period_ms: u64,
    pub debug: bool,
    pub env: HashMap<String, String>,
}

Runtime settings for a flow.

These settings control execution behavior like concurrency limits, timeouts, and circuit breaker configuration.

Fields

max_concurrent_executions: u32

Maximum concurrent trace executions.

execution_timeout_ms: u64

Execution timeout in milliseconds.

circuit_breaker_threshold: f64

Error rate threshold for circuit breaker (0.0 to 1.0).

circuit_breaker_window_ms: u64

Window for measuring error rate in milliseconds.

max_concurrent_versions: u32

Maximum concurrent versions during deployment.

drain_timeout_ms: u64

Drain timeout in milliseconds.

drain_grace_period_ms: u64

Grace period before hard drain in milliseconds.

debug: bool

Enable debug tracing for this flow.

env: HashMap<String, String>

Custom environment variables for this flow.

Implementations

impl FlowSettings

pub fn execution_timeout(&self) -> Duration

Get execution timeout as Duration.

pub fn circuit_breaker_window(&self) -> Duration

Get circuit breaker window as Duration.

pub fn drain_timeout(&self) -> Duration

Get drain timeout as Duration.

pub fn drain_grace_period(&self) -> Duration

Get drain grace period as Duration.

pub fn to_pipeline_settings(&self) -> PipelineSettings

Convert to PipelineSettings.

Trait Implementations

impl Clone for FlowSettings

fn clone(&self) -> FlowSettings

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for FlowSettings

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.

impl Default for FlowSettings

fn default() -> Self

Returns the “default value” for a type.

impl<'de> Deserialize<'de> for FlowSettings

where FlowSettings: Default,

fn deserialize<__D>(__deserializer: __D) -> Result<Self, __D::Error>

where __D: Deserializer<'de>,

Deserialize this value from the given Serde deserializer.

impl Serialize for FlowSettings

fn serialize<__S>(&self, __serializer: __S) -> Result<__S::Ok, __S::Error>

where __S: Serializer,

Serialize this value into the given Serde serializer.