Struct CheckpointConfig 

pub struct CheckpointConfig {

    pub interval: Option<Duration>,
    pub max_retained: usize,
    pub alignment_timeout: Duration,
    pub pre_commit_timeout: Duration,
    pub persist_timeout: Duration,
    pub commit_timeout: Duration,
    pub rollback_timeout: Duration,
    pub state_inline_threshold: usize,
    pub serialization_timeout: Duration,
    pub max_checkpoint_bytes: Option<usize>,
    pub quorum_timeout: Duration,
    pub restorable_gate_timeout: Duration,
    pub max_in_flight_epochs: u64,
    pub max_staged_bytes: u64,
}

Unified checkpoint configuration.

Timeouts prevent a stuck sink or hung filesystem from stalling the runtime. state_inline_threshold decides per-operator whether state inlines as base64 in the JSON manifest or lands in a sidecar file. max_checkpoint_bytes caps total sidecar size; an oversized checkpoint is rejected with [LDB-6014].

Fields

interval: Option<Duration>

Interval between checkpoints. None = manual only.

max_retained: usize

Number of completed checkpoints retained on disk/in object store.

alignment_timeout: Duration

Upper bound on barrier-alignment wait at fan-in operators.

pre_commit_timeout: Duration

Upper bound on sink pre-commit (phase 1).

persist_timeout: Duration

Upper bound on manifest persist.

commit_timeout: Duration

Upper bound on sink commit (phase 2).

rollback_timeout: Duration

Upper bound on sink rollback.

state_inline_threshold: usize

States larger than this go to a sidecar rather than base64 JSON.

serialization_timeout: Duration

Upper bound on operator state serialization.

max_checkpoint_bytes: Option<usize>

Cap on total sidecar bytes; None = no limit. 80% warn threshold.

quorum_timeout: Duration

Quorum wait timeout for checkpoint coordination.

restorable_gate_timeout: Duration

Max wait for every participating vnode’s partial to land before the epoch is declared restorable. Followers ack at capture and upload asynchronously after acking, so the leader’s durability gate polls for partial presence instead of checking once. Expiry aborts the epoch.

max_in_flight_epochs: u64

Maximum epochs admitted between Aligned and restorable — the upload backlog. Exactly-once pipelines are capped at 1: a single-open-transaction sink (e.g. a Kafka transactional producer) cannot overlap epochs.

max_staged_bytes: u64

Cap on captured-state bytes held in memory by in-flight epochs awaiting upload. At the cap, barrier admission pauses — cadence degrades to upload speed instead of exhausting memory.

Trait Implementations

impl Clone for CheckpointConfig

fn clone(&self) -> CheckpointConfig

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for CheckpointConfig

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

Formats the value using the given formatter.

impl Default for CheckpointConfig

fn default() -> Self

Returns the “default value” for a type.