Enum RecoveryStep 

pub enum RecoveryStep {
    LeaseExpired,
    CheckpointReload,
    Replay,
    ReadyForDispatch,
}

Steps of the zero-data-loss failure recovery pipeline.

Variants

LeaseExpired

Lease has expired or worker is gone; attempt is requeued.

CheckpointReload

Checkpoint for the run is (to be) reloaded.

Replay

Execution is (to be) replayed from checkpoint.

ReadyForDispatch

Attempt is ready to be dispatched to a new worker.

Implementations

impl RecoveryStep

pub fn pipeline() -> &'static [RecoveryStep]

Ordered sequence of steps for the pipeline.

Trait Implementations

impl Clone for RecoveryStep

fn clone(&self) -> RecoveryStep

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for RecoveryStep

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

Formats the value using the given formatter.

impl PartialEq for RecoveryStep

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

impl Eq for RecoveryStep

impl StructuralPartialEq for RecoveryStep