pub struct ChunkExecutionReport { /* private fields */ }Expand description
In-memory execution evidence returned by a chunk step.
Implementations§
Source§impl ChunkExecutionReport
impl ChunkExecutionReport
Sourcepub const fn outcome(&self) -> ChunkExecutionOutcome
pub const fn outcome(&self) -> ChunkExecutionOutcome
Returns the final chunk-step result.
Sourcepub const fn original_outcome(&self) -> Option<ChunkExecutionOutcome>
pub const fn original_outcome(&self) -> Option<ChunkExecutionOutcome>
Returns the result superseded by an after-listener failure.
Sourcepub const fn committed_counts(&self) -> ChunkCounts
pub const fn committed_counts(&self) -> ChunkCounts
Returns aggregate counts from committed chunks only.
Sourcepub const fn committed_chunks(&self) -> ChunkCount
pub const fn committed_chunks(&self) -> ChunkCount
Returns the number of committed chunk transactions.
Sourcepub const fn rolled_back_chunks(&self) -> ChunkCount
pub const fn rolled_back_chunks(&self) -> ChunkCount
Returns the number of rolled-back chunk transactions.
Sourcepub fn listener_failures(&self) -> &[ChunkListenerFailure]
pub fn listener_failures(&self) -> &[ChunkListenerFailure]
Borrows listener failures in callback execution order.
Sourcepub fn item_listener_failures(&self) -> &[ItemListenerFailure]
pub fn item_listener_failures(&self) -> &[ItemListenerFailure]
Borrows item, retry, and skip listener failures in execution order.
Sourcepub const fn skip_counts(&self) -> SkipCounts
pub const fn skip_counts(&self) -> SkipCounts
Returns committed per-phase skip counts.
A skip appears here only after the chunk that accepted it committed. On a repository-backed run the totals include the counts this attempt inherited, because the aggregate skip limit spans every attempt of one job instance.
Sourcepub const fn retry_counts(&self) -> RetryCounts
pub const fn retry_counts(&self) -> RetryCounts
Returns per-phase counts of durably reserved retry ordinals.
The counts include the ordinals this attempt inherited.
Sourcepub const fn rollback_count(&self) -> u64
pub const fn rollback_count(&self) -> u64
Returns framework rollback decisions with a durable acknowledgement.
A retry reservation and a terminal known rollback each add one. A database abort caused by process death is not counted. Unlike the skip and retry counts this value is scoped to the current attempt.
Sourcepub const fn no_rollback_count(&self) -> u64
pub const fn no_rollback_count(&self) -> u64
Returns commits that accepted a
RollbackDisposition::CommitSafeSkip, including inherited ones.
Trait Implementations§
Source§impl Clone for ChunkExecutionReport
impl Clone for ChunkExecutionReport
Source§fn clone(&self) -> ChunkExecutionReport
fn clone(&self) -> ChunkExecutionReport
1.0.0 (const: unstable) · Source§fn clone_from(&mut self, source: &Self)
fn clone_from(&mut self, source: &Self)
source. Read moreSource§impl Debug for ChunkExecutionReport
impl Debug for ChunkExecutionReport
impl Eq for ChunkExecutionReport
Source§impl PartialEq for ChunkExecutionReport
impl PartialEq for ChunkExecutionReport
impl StructuralPartialEq for ChunkExecutionReport
Auto Trait Implementations§
impl Freeze for ChunkExecutionReport
impl RefUnwindSafe for ChunkExecutionReport
impl Send for ChunkExecutionReport
impl Sync for ChunkExecutionReport
impl Unpin for ChunkExecutionReport
impl UnsafeUnpin for ChunkExecutionReport
impl UnwindSafe for ChunkExecutionReport
Blanket Implementations§
Source§impl<T> BorrowMut<T> for Twhere
T: ?Sized,
impl<T> BorrowMut<T> for Twhere
T: ?Sized,
Source§fn borrow_mut(&mut self) -> &mut T
fn borrow_mut(&mut self) -> &mut T
Source§impl<T> CloneToUninit for Twhere
T: Clone,
impl<T> CloneToUninit for Twhere
T: Clone,
Source§impl<Q, K> Equivalent<K> for Q
impl<Q, K> Equivalent<K> for Q
Source§fn equivalent(&self, key: &K) -> bool
fn equivalent(&self, key: &K) -> bool
key and return true if they are equal.Source§impl<Q, K> Equivalent<K> for Q
impl<Q, K> Equivalent<K> for Q
Source§impl<T> Instrument for T
impl<T> Instrument for T
Source§fn instrument(self, span: Span) -> Instrumented<Self> ⓘ
fn instrument(self, span: Span) -> Instrumented<Self> ⓘ
Source§fn in_current_span(self) -> Instrumented<Self> ⓘ
fn in_current_span(self) -> Instrumented<Self> ⓘ
Source§impl<T> IntoEither for T
impl<T> IntoEither for T
Source§fn into_either(self, into_left: bool) -> Either<Self, Self> ⓘ
fn into_either(self, into_left: bool) -> Either<Self, Self> ⓘ
self into a Left variant of Either<Self, Self>
if into_left is true.
Converts self into a Right variant of Either<Self, Self>
otherwise. Read moreSource§fn into_either_with<F>(self, into_left: F) -> Either<Self, Self> ⓘ
fn into_either_with<F>(self, into_left: F) -> Either<Self, Self> ⓘ
self into a Left variant of Either<Self, Self>
if into_left(&self) returns true.
Converts self into a Right variant of Either<Self, Self>
otherwise. Read more