Struct RecoveredState 

pub struct RecoveredState {
    pub epoch: u64,
    pub state_snapshot: Option<StateSnapshot>,
    pub wal_position: u64,
    pub wal_entries_replayed: u64,
    pub source_offsets: HashMap<String, u64>,
    pub watermark: Option<i64>,
    pub checkpoint_id: Option<u64>,
    pub state_changes: Vec<(Vec<u8>, Option<Vec<u8>>)>,
}

Recovered state from checkpoint + WAL replay.

Fields

epoch: u64

The epoch at which recovery completed.

state_snapshot: Option<StateSnapshot>

State snapshot (if checkpoint had state data).

wal_position: u64

WAL position after replay.

wal_entries_replayed: u64

Number of WAL entries replayed.

source_offsets: HashMap<String, u64>

Source offsets for exactly-once semantics.

watermark: Option<i64>

Watermark at recovery point.

checkpoint_id: Option<u64>

Checkpoint ID that was used (if any).

state_changes: Vec<(Vec<u8>, Option<Vec<u8>>)>

State changes from WAL replay (key, value or None for delete).

Implementations

impl RecoveredState

pub fn empty() -> Self

Creates a new empty recovered state.

pub fn has_state(&self) -> bool

Returns true if recovery found any state.

Trait Implementations

impl Debug for RecoveredState

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

Formats the value using the given formatter.