Struct CheckpointState 

pub struct CheckpointState {
    pub index_metadata: IndexMetadata,
    pub log_metadata: LogMetadata,
    pub checkpoint_type: CheckpointType,
    pub index_checkpoint_started: AtomicBool,
    pub index_checkpoint_completed: AtomicBool,
    pub log_flush_started: AtomicBool,
    pub log_flush_completed: AtomicBool,
    pub persistence_callback_invoked: AtomicBool,
    pub pending_persistence_calls: AtomicU64,
    pub prev_version: u32,
    pub is_incremental: bool,
}

State of an active checkpoint operation

Fields

index_metadata: IndexMetadata

Index metadata

log_metadata: LogMetadata

Log metadata

checkpoint_type: CheckpointType

Checkpoint type

index_checkpoint_started: AtomicBool

Index checkpoint started

index_checkpoint_completed: AtomicBool

Index checkpoint completed

log_flush_started: AtomicBool

Log flush started

log_flush_completed: AtomicBool

Log flush completed

persistence_callback_invoked: AtomicBool

Persistence callback invoked

pending_persistence_calls: AtomicU64

Number of pending persistence calls

prev_version: u32

Previous version (for incremental checkpoints)

is_incremental: bool

Whether this is an incremental checkpoint

Implementations

impl CheckpointState

pub fn new(checkpoint_type: CheckpointType) -> Self

Create a new checkpoint state

pub fn new_incremental(prev_state: &CheckpointState) -> Self

Create an incremental checkpoint state from a previous snapshot state

pub fn token(&self) -> CheckpointToken

Get the checkpoint token

pub fn is_complete(&self) -> bool

Check if checkpoint is complete

pub fn is_incremental_checkpoint(&self) -> bool

Check if this is an incremental checkpoint

pub fn reset(&mut self)

Reset the checkpoint state

pub fn start_index_checkpoint(&self) -> bool

Mark index checkpoint as started

pub fn complete_index_checkpoint(&self)

Mark index checkpoint as completed

pub fn start_log_flush(&self) -> bool

Mark log flush as started

pub fn complete_log_flush(&self)

Mark log flush as completed

pub fn increment_pending(&self)

Increment pending persistence calls

pub fn decrement_pending(&self) -> bool

Decrement pending persistence calls

Returns true if this was the last pending call

pub fn has_pending(&self) -> bool

Check if there are pending persistence calls

pub fn transfer(&self) -> Self

Transfer ownership of the checkpoint state (for incremental checkpoint chain)

Returns a clone of this state and resets the atomic fields

Trait Implementations

impl Clone for CheckpointState

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 CheckpointState

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

Formats the value using the given formatter.

impl Default for CheckpointState

fn default() -> Self

Returns the “default value” for a type.