Struct UnalignedCheckpointConfig 

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

Re-export from laminar_core::checkpoint::unaligned. Configuration for unaligned checkpoints.

Fields

enabled: bool

Whether unaligned checkpoints are enabled.

alignment_timeout_threshold: Duration

Duration after which aligned checkpoint falls back to unaligned.

max_inflight_buffer_bytes: usize

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

force_unaligned: bool

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

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<(), Error>

Formats the value using the given formatter.

impl Default for UnalignedCheckpointConfig

fn default() -> UnalignedCheckpointConfig

Returns the “default value” for a type.