Struct IncrementalConfig 

pub struct IncrementalConfig {
    pub checkpoint_threshold: usize,
    pub wal_sync_interval: usize,
    pub max_wal_size: usize,
    pub checkpoint_codec: Codec,
    pub sync_on_write: bool,
    pub keep_checkpoints: usize,
}

Configuration for incremental storage

Fields

checkpoint_threshold: usize

Number of WAL operations before triggering automatic checkpoint

wal_sync_interval: usize

Number of WAL operations before syncing to disk

max_wal_size: usize

Maximum WAL file size in bytes before forcing checkpoint

checkpoint_codec: Codec

Compression codec for checkpoints

sync_on_write: bool

Whether to fsync after each WAL write (slower but safer)

keep_checkpoints: usize

Keep old checkpoints for rollback (0 = delete immediately)

Implementations

impl IncrementalConfig

pub fn with_checkpoint_threshold(self, threshold: usize) -> Self

Set checkpoint threshold

pub fn with_wal_sync_interval(self, interval: usize) -> Self

Set WAL sync interval

pub fn with_max_wal_size(self, size: usize) -> Self

Set maximum WAL size

pub fn with_checkpoint_codec(self, codec: Codec) -> Self

Set checkpoint compression codec

pub fn with_sync_on_write(self, sync: bool) -> Self

Enable sync on every write (safer but slower)

pub fn with_keep_checkpoints(self, count: usize) -> Self

Set number of old checkpoints to keep

Trait Implementations

impl Clone for IncrementalConfig

fn clone(&self) -> IncrementalConfig

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for IncrementalConfig

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

Formats the value using the given formatter.

impl Default for IncrementalConfig

fn default() -> Self

Returns the “default value” for a type.

impl<'de> Deserialize<'de> for IncrementalConfig

fn deserialize<__D>(__deserializer: __D) -> Result<Self, __D::Error>

where __D: Deserializer<'de>,

Deserialize this value from the given Serde deserializer.

impl Serialize for IncrementalConfig

fn serialize<__S>(&self, __serializer: __S) -> Result<__S::Ok, __S::Error>

where __S: Serializer,

Serialize this value into the given Serde serializer.