Struct CheckpointPaths 

pub struct CheckpointPaths { /* private fields */ }

Deterministic path generator for checkpoint artifacts in object stores.

All paths are relative to a configurable base_prefix. This struct is stateless — it only computes paths, never performs I/O.

Implementations

impl CheckpointPaths

pub fn new(base_prefix: &str) -> Self

Create a new path generator with the given base prefix.

The prefix should end with / (one is appended if missing).

pub fn latest_pointer(&self) -> String

Path to the _latest pointer file.

pub fn checkpoint_dir(&self, id: &CheckpointId) -> String

Root directory for a specific checkpoint.

pub fn manifest(&self, id: &CheckpointId) -> String

Path to the manifest file for a checkpoint.

pub fn snapshot( &self, id: &CheckpointId, operator: &str, partition: u32, ) -> String

Path to a full state snapshot for an operator partition.

pub fn delta(&self, id: &CheckpointId, operator: &str, partition: u32) -> String

Path to an incremental delta for an operator partition.

pub fn source_offset(&self, id: &CheckpointId, source_name: &str) -> String

Path to a source offset file.

Trait Implementations

impl Clone for CheckpointPaths

fn clone(&self) -> CheckpointPaths

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for CheckpointPaths

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

Formats the value using the given formatter.

impl Default for CheckpointPaths

fn default() -> Self

Returns the “default value” for a type.