Struct GlobalCheckpoint 

pub struct GlobalCheckpoint {
    pub checkpoint_id: u64,
    pub operator_snapshots: HashMap<String, OperatorSnapshot>,
    pub created_at: Instant,
    pub total_size_bytes: usize,
    pub stream_positions: HashMap<String, u64>,
}

Consistent global snapshot across all operators in the streaming job.

Fields

checkpoint_id: u64

operator_snapshots: HashMap<String, OperatorSnapshot>

created_at: Instant

total_size_bytes: usize

stream_positions: HashMap<String, u64>

Stream read offsets at the time of the checkpoint. Maps stream_id → offset, allowing the job to replay exactly from here.

Implementations

impl GlobalCheckpoint

pub fn new(checkpoint_id: u64) -> Self

Create an empty global checkpoint container.

pub fn add_operator_snapshot(&mut self, snapshot: OperatorSnapshot)

Add an operator snapshot to this global checkpoint.

pub fn set_stream_position(&mut self, stream_id: impl Into<String>, offset: u64)

Set the committed read offset for a stream.

pub fn is_complete(&self, expected_operators: &[String]) -> bool

Returns true when every expected operator has contributed a snapshot.

pub fn total_bytes(&self) -> usize

Total byte size of all operator state in this checkpoint.

Trait Implementations

impl Clone for GlobalCheckpoint

fn clone(&self) -> GlobalCheckpoint

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for GlobalCheckpoint

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

Formats the value using the given formatter.