Struct DagCheckpointConfig 

pub struct DagCheckpointConfig {
    pub interval: Duration,
    pub barrier_type: BarrierType,
    pub alignment_timeout: Duration,
    pub incremental: bool,
    pub max_concurrent: usize,
    pub max_retained: usize,
}

Configuration for DAG checkpointing.

Fields

interval: Duration

How often to trigger checkpoints.

barrier_type: BarrierType

Barrier alignment strategy.

alignment_timeout: Duration

Maximum time to wait for barrier alignment at fan-in nodes.

incremental: bool

Whether to use incremental checkpoints (future use).

max_concurrent: usize

Maximum number of concurrent in-flight checkpoints.

max_retained: usize

Maximum number of completed snapshots to retain.

Trait Implementations

impl Clone for DagCheckpointConfig

fn clone(&self) -> DagCheckpointConfig

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for DagCheckpointConfig

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

Formats the value using the given formatter.

impl Default for DagCheckpointConfig

fn default() -> Self

Returns the “default value” for a type.