Struct OperatorSnapshot 

pub struct OperatorSnapshot {
    pub operator_id: String,
    pub checkpoint_id: u64,
    pub state_bytes: Vec<u8>,
    pub in_flight_messages: Vec<Vec<u8>>,
    pub created_at: Instant,
    pub size_bytes: usize,
}

Snapshot of a single operator’s state at checkpoint time.

Fields

operator_id: String

ID of the operator that produced this snapshot.

checkpoint_id: u64

The checkpoint this snapshot belongs to.

state_bytes: Vec<u8>

Serialised state bytes (format is operator-specific).

in_flight_messages: Vec<Vec<u8>>

In-flight messages that were in the channel when the barrier arrived.

created_at: Instant

Wall-clock time at snapshot creation.

size_bytes: usize

Total byte size for budget tracking.

Implementations

impl OperatorSnapshot

pub fn new( operator_id: impl Into<String>, checkpoint_id: u64, state_bytes: Vec<u8>, in_flight_messages: Vec<Vec<u8>>, ) -> Self

Create a new operator snapshot, auto-computing size_bytes.

Trait Implementations

impl Clone for OperatorSnapshot

fn clone(&self) -> OperatorSnapshot

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for OperatorSnapshot

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

Formats the value using the given formatter.