Struct StreamingCheckpointManager 

pub struct StreamingCheckpointManager { /* private fields */ }

Zero-copy streaming checkpoint manager [50].

Eliminates Muda of Processing by streaming directly from serializer to compressor to memory-mapped file without intermediate allocations.

Implementations

impl StreamingCheckpointManager

pub fn new( base_path: impl Into<PathBuf>, interval: u64, compression_level: i32, ) -> SimResult<Self>

Create a new streaming checkpoint manager.

Errors

Returns error if base path cannot be created.

pub const fn should_checkpoint(&self, step: u64) -> bool

Check if checkpoint should be created at this step.

pub fn checkpoint_streaming<S: Serialize>( &mut self, time: SimTime, step: u64, state: &S, rng_state: &RngState, ) -> SimResult<PathBuf>

Create checkpoint with streaming serialization (zero intermediate allocation).

Errors

Returns error if serialization or file I/O fails.

pub fn restore_streaming<S: DeserializeOwned>( &self, path: &Path, ) -> SimResult<(CheckpointHeader, S)>

Restore state from streaming checkpoint.

Errors

Returns error if deserialization fails.

pub const fn checkpoint_count(&self) -> usize

Get checkpoint count.

pub const fn total_bytes_written(&self) -> usize

Get total bytes written.

Trait Implementations

impl Debug for StreamingCheckpointManager

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

Formats the value using the given formatter.