Struct BatchExecutionState 

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

Shared state collected while a batch executor is running.

Implementations

impl<E> BatchExecutionState<E>

pub const fn new(task_count: usize) -> Self

Creates empty execution state for a declared task count.

Parameters

• task_count - Declared number of tasks in the batch.

Returns

Empty execution state.

pub fn record_task_observed(&self) -> usize

Records one observed task.

Returns

The observed task count after this task was recorded.

pub fn record_task_started(&self)

Records that one task has started.

pub fn record_task_succeeded(&self)

Records one successful task completion.

Panics

Panics if no active task was recorded for this completion.

pub fn record_task_failed(&self, index: usize, error: E)

Records one task error.

Parameters

• index - Zero-based task index.
• error - Task error returned by the task.

Panics

Panics if no active task was recorded for this completion.

pub fn record_task_panicked(&self, index: usize, error: BatchTaskError<E>)

Records one task panic.

Parameters

• index - Zero-based task index.
• error - Captured task panic.

Panics

Panics if no active task was recorded for this completion.

pub fn progress_counters(&self) -> ProgressCounters

Returns generic progress counters for this execution state.

Returns

Counters suitable for progress reporting.

pub fn into_outcome(self, elapsed: Duration) -> BatchOutcome<E>

Consumes this state and builds a batch outcome.

Parameters

• elapsed - Monotonic elapsed duration.

Returns

The final or partial outcome represented by this state.