Enum CheckpointDependencies 

pub enum CheckpointDependencies {
    V2 {
        batches: Vec<String>,
        state_files: Vec<String>,
    },
    V1(Vec<String>),
}

Serialized form of dependencies.json on disk.

Two formats. New checkpoints write the struct form (V2) carrying both the batch list referenced at the storage root and the list of per-operator state files inside the checkpoint dir. Old checkpoints stored only the batch-filename array (V1); they remain readable so a rolling upgrade across in-flight checkpoints is safe.

Variants

V2

Fields

batches: Vec<String>

Batch filenames at the storage root (w*.feldera) that the checkpoint references for GC retention.

state_files: Vec<String>

Per-operator state filenames inside the checkpoint dir (e.g. pspine-*.dat, z1-*.dat, CHECKPOINT). Consumed by restore-time verification. Defaulted to empty for forward compat.

V1(Vec<String>)

Legacy form: JSON array of batch filenames at the storage root (w*.feldera). No state-file manifest.

Implementations

impl CheckpointDependencies

pub fn batches(&self) -> &[String]

Batch files the checkpoint references at the storage root (w*.feldera). Present in both V1 and V2 checkpoints.

pub fn state_files(&self) -> &[String]

Per-operator state files the checkpoint owned at commit time. These live inside the checkpoint dir (e.g. pspine-*.dat, z1-*.dat). Empty for V1 checkpoints, which predate the state-file manifest.

Trait Implementations

impl Debug for CheckpointDependencies

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

Formats the value using the given formatter.

impl<'de> Deserialize<'de> for CheckpointDependencies

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

where __D: Deserializer<'de>,

Deserialize this value from the given Serde deserializer.