Struct CheckpointState 

pub struct CheckpointState {
    pub last_checkpoint: Option<Time>,
    pub last_message: Option<String>,
    pub checkpoint_count: u64,
}

State for tracking checkpoint progress.

This struct tracks progress reporting checkpoints, which are distinct from cancellation checkpoints. Progress checkpoints indicate that a task is making forward progress and are useful for:

• Detecting stuck/stalled tasks
• Work-stealing scheduler decisions
• Observability and debugging

Fields

last_checkpoint: Option<Time>

The runtime time of the last checkpoint.

last_message: Option<String>

The message from the last checkpoint_with() call.

checkpoint_count: u64

The total number of checkpoints recorded.

Implementations

impl CheckpointState

pub fn new() -> Self

Creates a new checkpoint state with no recorded checkpoints.

pub fn record(&mut self)

Records a checkpoint without a message.

pub fn record_at(&mut self, at: Time)

Records a checkpoint at an explicit runtime time.

pub fn record_with_message(&mut self, message: String)

Records a checkpoint with a message.

pub fn record_with_message_at(&mut self, message: String, at: Time)

Records a checkpoint with a message at an explicit runtime time.

Trait Implementations

impl Clone for CheckpointState

fn clone(&self) -> CheckpointState

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.