Struct StreamCheckpointConfig 

pub struct StreamCheckpointConfig {
    pub interval_ms: Option<u64>,
    pub timeout_ms: Option<u64>,
    pub data_dir: Option<PathBuf>,
    pub max_retained: Option<usize>,
    pub max_staged_bytes: Option<u64>,
}

Configuration for streaming checkpoints.

Fields

interval_ms: Option<u64>

Checkpoint interval in milliseconds. None = manual only.

timeout_ms: Option<u64>

One end-to-end attempt deadline in milliseconds, spanning sink fencing, alignment, capture, durable publication, and completion delivery. None = default (120_000).

data_dir: Option<PathBuf>

Directory for persisting checkpoints. None uses the database storage directory, then falls back to ./data; it never silently selects volatile checkpoint storage.

max_retained: Option<usize>

Number of predecessor checkpoints retained alongside the current recovery cut. None = default (3); predecessors keep reference/delta chains resolvable.

max_staged_bytes: Option<u64>

Maximum bytes admitted for one checkpoint across in-flight capture and persisted/restored external state. None uses DEFAULT_MAX_CHECKPOINT_STATE_BYTES.

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() -> StreamCheckpointConfig

Returns the “default value” for a type.