Enum SourceOutcome 

pub enum SourceOutcome {
    SkippedNotLeader,
    NoData,
    Ingested {
        messages: usize,
    },
    CursorRaceLost,
}

The outcome of one run_source_once tick.

Variants

SkippedNotLeader

Another replica held the lease; this tick did not poll.

NoData

Polled, but the source returned nothing new and left the cursor where it was; nothing to do.

Ingested

Advanced the cursor and ingested messages messages. messages is 0 when the source advanced the watermark without emitting — e.g. it skipped a poison message and moved past it.

Fields

messages: usize

How many messages the poll returned (before spine dedup); may be 0.

CursorRaceLost

The cursor advance was rejected — another replica had already moved it on (a lease-boundary race). The transaction rolled back; nothing ingested.

Trait Implementations

impl Clone for SourceOutcome

fn clone(&self) -> SourceOutcome

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for SourceOutcome

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

Formats the value using the given formatter.

impl Eq for SourceOutcome

impl PartialEq for SourceOutcome

fn eq(&self, other: &SourceOutcome) -> bool

Equality operator ==.

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

Inequality operator !=.

impl StructuralPartialEq for SourceOutcome