Enum PushOutcome 

#[non_exhaustive]
pub enum PushOutcome {
    Done,
    Blocked {
        resume_at: usize,
        reason: BlockReason,
    },
    Fatal(FatalError),
}

Result of pushing one batch (or a resumed suffix of one) through a chain.

Variants (Non-exhaustive)

Non-exhaustive enums could have additional variants added in future. Therefore, when matching against variants of non-exhaustive enums, an extra wildcard arm must be added to account for any future variants.

Done

Every payload was fully processed (records may have been filtered or skipped by policy along the way).

Blocked

The batch could not complete yet. Payloads with index < resume_at are fully processed; the driver later re-pushes the same batch with from = resume_at. Any partially-emitted payload’s already-emitted records are parked inside the terminal stage and drain first on resume — operators never re-run for them.

Fields

resume_at: usize

Index of the first payload not yet fully processed.

reason: BlockReason

What the batch is waiting for.

Fatal(FatalError)

A Fail-policy stage tripped or an invariant broke. The batch’s AckRef must be failed by the driver; the pipeline stops.

Trait Implementations

impl Debug for PushOutcome

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

Formats the value using the given formatter.