Struct Checkpoint 

pub struct Checkpoint {

    pub shard: u32,
    pub shards: u32,
    pub lsn: Lsn,
    pub next_run: RunId,
    pub store_generation: u64,
    pub store_len: u64,
    pub created_ms: u64,
    pub runs: Vec<CheckpointRun>,
    pub outbox: Vec<u8>,
    pub log_position: u64,
    pub index: Option<Vec<BlobRef>>,
    pub obsolete: u64,
    pub index_runs: u64,
}

Fields

shard: u32

shards: u32

lsn: Lsn

Every record at or before this LSN is reflected here or in the store.

next_run: RunId

store_generation: u64

store_len: u64

created_ms: u64

runs: Vec<CheckpointRun>

outbox: Vec<u8>

Messages to other shards not yet acknowledged (host-defined encoding). The log after lsn regenerates newer ones.

log_position: u64

Log format 3: the sequence of the first batch of the shared log that can hold this shard’s records after lsn. 0 in format 2, where each shard’s segments start after its checkpoint on their own.

index: Option<Vec<BlobRef>>

Checkpoint format 3: the Index frames in the run store prefix that together list every parked run, oldest first (later records for a run supersede earlier ones). None: recovery scans the store.

obsolete: u64

Bytes of the store prefix no longer in use, for compaction.

index_runs: u64

Format 3: how many runs the index lists (it may hold more records, superseded ones), so recovery sizes the table once.

Implementations

impl Checkpoint

pub fn encode(&self) -> Vec<u8>

pub fn decode(bytes: &[u8]) -> DecodeResult<Self>

Trait Implementations

impl Clone for Checkpoint

fn clone(&self) -> Self

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for Checkpoint

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

Formats the value using the given formatter.

impl Eq for Checkpoint

impl PartialEq for Checkpoint

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

Equality operator ==.

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

Inequality operator !=.

impl StructuralPartialEq for Checkpoint