Struct OperatorCheckpoint 

pub struct OperatorCheckpoint {
    pub state_b64: Option<String>,
    pub external: bool,
    pub external_offset: u64,
    pub external_length: u64,
}

Serialized operator state stored in the manifest.

Fields

state_b64: Option<String>

Base64-encoded binary state (for small payloads inlined in JSON).

external: bool

If true, state is stored externally in the state.bin sidecar file.

external_offset: u64

Byte offset into the state.bin file (if external).

external_length: u64

Byte length of the state in the state.bin file (if external).

Implementations

impl OperatorCheckpoint

pub fn inline(data: &[u8]) -> Self

Creates an inline operator checkpoint from raw bytes.

The bytes are base64-encoded for JSON storage.

pub fn external(offset: u64, length: u64) -> Self

Creates an external reference to state in the sidecar file.

pub fn decode_inline(&self) -> Option<Vec<u8>>

Decodes the inline state, returning the raw bytes.

Returns None if the state is external, no inline data is present, or if the base64 data is corrupted (logs a warning in that case).

pub fn try_decode_inline(&self) -> Result<Option<Vec<u8>>, String>

Decodes the inline state, returning a Result for callers that need to distinguish between “no inline state” and “corrupted state”.

Returns Ok(None) if no inline data is present (external or absent). Returns Ok(Some(bytes)) on successful decode.

Errors

Returns Err if base64 data is present but corrupted.

pub fn from_bytes( data: &[u8], threshold: usize, current_offset: u64, ) -> (Self, Option<Vec<u8>>)

Creates an OperatorCheckpoint from raw bytes using a size threshold.

If data.len() <= threshold, the state is inlined as base64. If data.len() > threshold, the state is marked as external with the given offset and length, and the raw data is returned for sidecar storage.

Arguments

• data — Raw operator state bytes
• threshold — Maximum size in bytes for inline storage
• current_offset — Byte offset into the sidecar file for this blob

Returns

A tuple of the checkpoint entry and optional raw data for the sidecar.

Trait Implementations

impl Clone for OperatorCheckpoint

fn clone(&self) -> OperatorCheckpoint

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for OperatorCheckpoint

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

Formats the value using the given formatter.

impl<'de> Deserialize<'de> for OperatorCheckpoint

fn deserialize<__D>(__deserializer: __D) -> Result<Self, __D::Error>

where __D: Deserializer<'de>,

Deserialize this value from the given Serde deserializer.

impl PartialEq for OperatorCheckpoint

fn eq(&self, other: &OperatorCheckpoint) -> bool

Tests for self and other values to be equal, and is used by ==.

fn ne(&self, other: &Rhs) -> bool

Tests for !=. The default implementation is almost always sufficient, and should not be overridden without very good reason.

impl Serialize for OperatorCheckpoint

fn serialize<__S>(&self, __serializer: __S) -> Result<__S::Ok, __S::Error>

where __S: Serializer,

Serialize this value into the given Serde serializer.

impl Eq for OperatorCheckpoint

impl StructuralPartialEq for OperatorCheckpoint