Struct UnalignedCheckpointConfig 

pub struct UnalignedCheckpointConfig {
    pub enabled: bool,
    pub alignment_timeout_threshold: Duration,
    pub max_inflight_buffer_bytes: usize,
    pub force_unaligned: bool,
}

Configuration for unaligned checkpoints.

When barrier alignment takes too long (due to backpressure on slow inputs), the checkpoint can fall back to an unaligned snapshot that captures in-flight data from channels. This trades larger checkpoint size for faster completion.

Fields

enabled: bool

Whether unaligned checkpoints are enabled.

alignment_timeout_threshold: Duration

Duration after which aligned checkpoint falls back to unaligned.

If all barriers don’t arrive within this threshold after the first barrier, the checkpoint switches to unaligned mode. Default: 10s.

max_inflight_buffer_bytes: usize

Maximum bytes of in-flight data to buffer per checkpoint.

If the total in-flight data exceeds this, the checkpoint fails rather than consuming unbounded memory. Default: 256 MB.

force_unaligned: bool

Force unaligned mode for all checkpoints (skip aligned attempt).

Useful for testing or when backpressure is known to be persistent.

Trait Implementations

impl Clone for UnalignedCheckpointConfig

fn clone(&self) -> UnalignedCheckpointConfig

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for UnalignedCheckpointConfig

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

Formats the value using the given formatter.

impl Default for UnalignedCheckpointConfig

fn default() -> Self

Returns the “default value” for a type.