Enum AwaitOutcome 

pub enum AwaitOutcome {
    Reached(u32),
    TimedOut {
        observed: u32,
        required: u32,
    },
    NotRequired,
}

Variants

Reached(u32)

At least required replicas reached target_lsn before the deadline. The returned count is the number observed at the moment we unblocked (may exceed required if many replicas were already ahead).

TimedOut

The deadline expired with fewer than required replicas at or past target_lsn. The count we observed is included so the caller can log how close we got.

Fields

observed: u32

required: u32

NotRequired

required == 0 — degenerate case, returns immediately. No replica state is consulted.

Trait Implementations

impl Clone for AwaitOutcome

fn clone(&self) -> AwaitOutcome

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for AwaitOutcome

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

Formats the value using the given formatter.

impl PartialEq for AwaitOutcome

fn eq(&self, other: &AwaitOutcome) -> 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 Copy for AwaitOutcome

impl Eq for AwaitOutcome

impl StructuralPartialEq for AwaitOutcome