Struct StreamCheckpointConfig 

pub struct StreamCheckpointConfig {
    pub interval_ms: Option<u64>,
    pub recent_read_interval_ms: Option<u64>,
    pub timeout_ms: Option<u64>,
    pub data_dir: Option<PathBuf>,
    pub max_node_data_bytes: Option<u64>,
    pub sink_epoch_gate_stall_timeout_ms: Option<u64>,
}

Configuration for streaming checkpoints.

Fields

interval_ms: Option<u64>

Checkpoint interval in milliseconds. None = manual only.

recent_read_interval_ms: Option<u64>

While a recent committed read waits for a newer checkpoint, the next periodic checkpoint starts this long after the previous one ended instead of interval_ms. Must be shorter than interval_ms. None = recent reads wait for the periodic cadence.

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_node_data_bytes: Option<u64>

Maximum bytes admitted for one participant’s checkpoint node-data object. None uses DEFAULT_MAX_CHECKPOINT_NODE_DATA_BYTES.

sink_epoch_gate_stall_timeout_ms: Option<u64>

A cycle waiting to write into a checkpoint-committable sink fails as a recoverable fault when the sink’s epoch gate stays in one state this long, in milliseconds. Must exceed interval_ms plus the checkpoint timeout, so it needs periodic checkpoints. None = the write waits for as long as the epoch stays closed.

Trait Implementations

impl Clone for StreamCheckpointConfig

fn clone(&self) -> Self

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.