Enum CheckpointPhase 

pub enum CheckpointPhase {
    Idle,
    InProgress {
        checkpoint_id: u64,
        started_at: Instant,
        acked_operators: HashSet<String>,
    },
    Completed {
        checkpoint_id: u64,
        completed_at: Instant,
        size_bytes: usize,
    },
    Failed {
        checkpoint_id: u64,
        reason: String,
    },
}

Lifecycle phase of the checkpoint coordinator.

Variants

Idle

No checkpoint in progress.

InProgress

Coordinator sent barrier markers; waiting for operators to respond.

Fields

checkpoint_id: u64

started_at: Instant

acked_operators: HashSet<String>

Completed

All operators have reported; checkpoint is permanently stored.

Fields

checkpoint_id: u64

completed_at: Instant

size_bytes: usize

Failed

Checkpoint was abandoned.

Fields

checkpoint_id: u64

reason: String

Implementations

impl CheckpointPhase

pub fn checkpoint_id(&self) -> Option<u64>

Return the checkpoint ID for phases that have one.

Trait Implementations

impl Clone for CheckpointPhase

fn clone(&self) -> CheckpointPhase

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for CheckpointPhase

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

Formats the value using the given formatter.

impl PartialEq for CheckpointPhase

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