Struct CompletionConfig 

pub struct CompletionConfig {
    pub min_successful: Option<usize>,
    pub tolerated_failure_count: Option<usize>,
    pub tolerated_failure_percentage: Option<f64>,
}

Configuration defining success/failure criteria for concurrent operations.

Fields

min_successful: Option<usize>

Minimum number of successful completions required.

tolerated_failure_count: Option<usize>

Maximum number of tolerated failures (absolute count).

tolerated_failure_percentage: Option<f64>

Maximum percentage of tolerated failures (0.0 to 1.0).

Implementations

impl CompletionConfig

pub fn first_successful() -> Self

Creates a completion config that succeeds when the first task succeeds.

Example

use durable_execution_sdk::CompletionConfig;

let config = CompletionConfig::first_successful();
assert_eq!(config.min_successful, Some(1));

pub fn all_completed() -> Self

Creates a completion config that waits for all tasks to complete.

Example

use durable_execution_sdk::CompletionConfig;

let config = CompletionConfig::all_completed();
assert!(config.min_successful.is_none());

pub fn all_successful() -> Self

Creates a completion config that requires all tasks to succeed.

Example

use durable_execution_sdk::CompletionConfig;

let config = CompletionConfig::all_successful();
assert_eq!(config.tolerated_failure_count, Some(0));
assert_eq!(config.tolerated_failure_percentage, Some(0.0));

pub fn with_min_successful(count: usize) -> Self

Creates a completion config with a specific minimum successful count.

pub fn with_failure_tolerance(count: usize) -> Self

Creates a completion config with a specific failure tolerance.

Trait Implementations

impl Clone for CompletionConfig

fn clone(&self) -> CompletionConfig

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for CompletionConfig

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

Formats the value using the given formatter.

impl Default for CompletionConfig

fn default() -> CompletionConfig

Returns the “default value” for a type.

impl<'de> Deserialize<'de> for CompletionConfig

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

where __D: Deserializer<'de>,

Deserialize this value from the given Serde deserializer.

impl Serialize for CompletionConfig

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

where __S: Serializer,

Serialize this value into the given Serde serializer.