Struct BatchResult 

pub struct BatchResult<T> {
    pub items: Vec<BatchItem<T>>,
    pub completion_reason: CompletionReason,
}

Result of a batch operation (map or parallel).

Contains results for all items and the reason for completion.

Examples

use durable_execution_sdk::concurrency::{BatchResult, BatchItem, CompletionReason};

// Create a batch result with some items
let items = vec![
    BatchItem::succeeded(0, "first"),
    BatchItem::succeeded(1, "second"),
    BatchItem::failed(2, durable_execution_sdk::ErrorObject::new("Error", "Failed")),
];
let result = BatchResult::new(items, CompletionReason::AllCompleted);

assert_eq!(result.success_count(), 2);
assert_eq!(result.failure_count(), 1);
assert_eq!(result.total_count(), 3);
assert!(!result.all_succeeded());
assert!(result.has_failures());

Fields

items: Vec<BatchItem<T>>

Results for each item in the batch

completion_reason: CompletionReason

Reason why the batch completed

Implementations

impl<T> BatchResult<T>

pub fn new( items: Vec<BatchItem<T>>, completion_reason: CompletionReason, ) -> Self

Creates a new BatchResult.

pub fn empty() -> Self

Creates an empty BatchResult with AllCompleted reason.

pub fn succeeded(&self) -> Vec<&BatchItem<T>>

Returns all succeeded items.

pub fn failed(&self) -> Vec<&BatchItem<T>>

Returns all failed items.

pub fn get_results(&self) -> Result<Vec<&T>, DurableError>

Returns all results from succeeded items.

Returns an error if any item failed and the completion reason indicates failure tolerance was exceeded.

pub fn success_count(&self) -> usize

Returns the number of succeeded items.

pub fn failure_count(&self) -> usize

Returns the number of failed items.

pub fn total_count(&self) -> usize

Returns the total number of items.

pub fn all_succeeded(&self) -> bool

Returns true if all items succeeded.

pub fn has_failures(&self) -> bool

Returns true if any item failed.

pub fn is_failure(&self) -> bool

Returns true if the batch completed due to failure tolerance being exceeded.

pub fn is_success(&self) -> bool

Returns true if the batch completed successfully (min successful reached or all completed).

Trait Implementations

impl<T: Clone> Clone for BatchResult<T>

fn clone(&self) -> BatchResult<T>

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl<T: Debug> Debug for BatchResult<T>

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

Formats the value using the given formatter.

impl<T> Default for BatchResult<T>

fn default() -> Self

Returns the “default value” for a type.

impl<'de, T> Deserialize<'de> for BatchResult<T>

where T: Deserialize<'de>,

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

where __D: Deserializer<'de>,

Deserialize this value from the given Serde deserializer.

impl<T> Serialize for BatchResult<T>

where T: Serialize,

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

where __S: Serializer,

Serialize this value into the given Serde serializer.