Struct StreamCheckpointConfig 

pub struct StreamCheckpointConfig {
    pub interval_ms: Option<u64>,
    pub wal_mode: Option<WalMode>,
    pub data_dir: Option<PathBuf>,
    pub changelog_capacity: Option<usize>,
    pub max_retained: Option<usize>,
    pub overflow_policy: OverflowPolicy,
}

Configuration for streaming checkpoints.

All fields default to None/disabled. Checkpointing is opt-in.

Fields

interval_ms: Option<u64>

Checkpoint interval in milliseconds. None = manual only.

wal_mode: Option<WalMode>

WAL mode. Requires data_dir to be set.

data_dir: Option<PathBuf>

Directory for persisting checkpoints/WAL. None = in-memory only.

changelog_capacity: Option<usize>

Changelog buffer capacity. None = no changelog buffer.

max_retained: Option<usize>

Maximum number of retained checkpoints. None = unlimited.

overflow_policy: OverflowPolicy

Overflow policy for the changelog buffer.

Implementations

impl StreamCheckpointConfig

pub fn validate(&self) -> Result<(), CheckpointError>

Validates the configuration, returning an error if invalid.

Errors

Returns CheckpointError::InvalidConfig if WAL mode is set without data_dir, or if changelog_capacity is zero.

Trait Implementations

impl Clone for StreamCheckpointConfig

fn clone(&self) -> StreamCheckpointConfig

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for StreamCheckpointConfig

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

Formats the value using the given formatter.

impl Default for StreamCheckpointConfig

fn default() -> Self

Returns the “default value” for a type.