Struct CheckpointWriter 

pub struct CheckpointWriter { /* private fields */ }

Buffered checkpoint writer for resume logging.

Entries are buffered in memory and flushed to disk when either:

• The buffer reaches flush_threshold entries, or
• flush_interval has elapsed since the last flush.

Implementations

impl CheckpointWriter

pub fn new( log_file: impl AsRef<Path>, flush_threshold: usize, flush_interval: Duration, ) -> Self

Create a new checkpoint writer.

• log_file: Path to the checkpoint log file (appended to).
• flush_threshold: Maximum entries before auto-flush (default: 128).
• flush_interval: Maximum time between flushes (default: 250ms).

pub fn with_defaults(log_file: impl AsRef<Path>) -> Self

Create with default settings (threshold=128, interval=250ms).

pub fn write(&self, entry: impl Into<String>)

Buffer a checkpoint entry, flushing if thresholds are reached.

pub fn flush(&self)

Force-flush all buffered entries to disk.

pub fn close(self)

Flush and close (consumes the writer).