Struct StreamCheckpoint 

pub struct StreamCheckpoint {
    pub id: u64,
    pub epoch: u64,
    pub source_sequences: HashMap<String, u64>,
    pub sink_positions: HashMap<String, u64>,
    pub watermarks: HashMap<String, i64>,
    pub operator_states: HashMap<String, Vec<u8>>,
    pub created_at: u64,
}

A point-in-time snapshot of streaming pipeline state.

Fields

id: u64

Unique checkpoint identifier (monotonically increasing).

epoch: u64

Epoch number.

source_sequences: HashMap<String, u64>

Source name -> sequence number at checkpoint time.

sink_positions: HashMap<String, u64>

Sink name -> position at checkpoint time.

watermarks: HashMap<String, i64>

Source name -> watermark at checkpoint time.

operator_states: HashMap<String, Vec<u8>>

Operator name -> opaque state bytes.

created_at: u64

Timestamp when this checkpoint was created (millis since epoch).

Implementations

impl StreamCheckpoint

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

Serializes the checkpoint to bytes.

Format:

[version: 1][id: 8][epoch: 8][created_at: 8]
[num_sources: 4][ [name_len:4][name][seq:8] ... ]
[num_sinks: 4][ [name_len:4][name][pos:8] ... ]
[num_watermarks: 4][ [name_len:4][name][wm:8] ... ]
[num_ops: 4][ [name_len:4][name][data_len:4][data] ... ]

pub fn from_bytes(data: &[u8]) -> Result<Self, CheckpointError>

Deserializes a checkpoint from bytes.

Errors

Returns CheckpointError::IoError if the data is truncated, corrupted, or uses an unsupported version.

Trait Implementations

impl Clone for StreamCheckpoint

fn clone(&self) -> StreamCheckpoint

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for StreamCheckpoint

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

Formats the value using the given formatter.