Struct BatchOutcomeBuilder 

pub struct BatchOutcomeBuilder<E> { /* private fields */ }

Builder carrying validated parts for a crate::BatchOutcome.

The builder checks aggregate counters, failure detail count, duplicate indexes, and failed-versus-panicked detail counts before creating an outcome.

use qubit_batch::{
    BatchOutcomeBuilder,
    BatchTaskError,
    BatchTaskFailure,
};

let outcome = BatchOutcomeBuilder::builder(2)
    .completed_count(2)
    .succeeded_count(1)
    .failed_count(1)
    .failures(vec![BatchTaskFailure::new(
        1,
        BatchTaskError::Failed("invalid row"),
    )])
    .build()
    .expect("outcome counters should match failure details");

assert_eq!(outcome.failed_count(), 1);
assert_eq!(outcome.failures()[0].index(), 1);

Implementations

impl<E> BatchOutcomeBuilder<E>

pub fn builder(task_count: usize) -> Self

Starts building a batch outcome.

Parameters

• task_count - Declared task count for the batch.

Returns

A builder initialized with zero counters, zero elapsed time, and no failures.

pub const fn completed_count(self, completed_count: usize) -> Self

Sets the number of tasks that finished.

Parameters

• completed_count - Number of tasks that reached a terminal outcome.

Returns

The updated builder.

pub const fn succeeded_count(self, succeeded_count: usize) -> Self

Sets the number of successful tasks.

Parameters

• succeeded_count - Number of tasks that completed successfully.

Returns

The updated builder.

pub const fn failed_count(self, failed_count: usize) -> Self

Sets the number of tasks that returned their own error.

Parameters

• failed_count - Number of tasks that failed with task errors.

Returns

The updated builder.

pub const fn panicked_count(self, panicked_count: usize) -> Self

Sets the number of tasks that panicked.

Parameters

• panicked_count - Number of tasks that panicked.

Returns

The updated builder.

pub const fn elapsed(self, elapsed: Duration) -> Self

Sets the total monotonic elapsed duration.

Parameters

• elapsed - Total monotonic elapsed duration.

Returns

The updated builder.

pub fn failures(self, failures: Vec<BatchTaskFailure<E>>) -> Self

Sets the detailed failure records.

Parameters

• failures - Detailed task failure records.

Returns

The updated builder.

pub fn validate(self) -> Result<Self, BatchOutcomeBuildError>

Validates this builder and sorts failure records by task index.

Returns

Ok(builder) when the counters and failure details are consistent.

Errors

Returns BatchOutcomeBuildError when the counters or failure details are inconsistent.

pub fn build(self) -> Result<BatchOutcome<E>, BatchOutcomeBuildError>

Validates this builder and creates a batch outcome.

Returns

Ok(outcome) when the counters and failure details are consistent.

Errors

Returns BatchOutcomeBuildError when the counters or failure details are inconsistent.

Trait Implementations

impl<E: Clone> Clone for BatchOutcomeBuilder<E>

fn clone(&self) -> BatchOutcomeBuilder<E>

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl<E: Debug> Debug for BatchOutcomeBuilder<E>

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

Formats the value using the given formatter.

impl<E: PartialEq> PartialEq for BatchOutcomeBuilder<E>

fn eq(&self, other: &BatchOutcomeBuilder<E>) -> bool

Tests for self and other values to be equal, and is used by ==.

fn ne(&self, other: &Rhs) -> bool

Tests for !=. The default implementation is almost always sufficient, and should not be overridden without very good reason.

impl<E: Eq> Eq for BatchOutcomeBuilder<E>

impl<E> StructuralPartialEq for BatchOutcomeBuilder<E>