Struct PersistenceConfig 

pub struct PersistenceConfig {
    pub strategy: PersistenceStrategy,
    pub flush_policy: FlushPolicy,
    pub max_buffered_entries: usize,
    pub flush_workers: usize,
    pub channel_capacity: usize,
}

Configuration parameters for log persistence behavior

Fields

strategy: PersistenceStrategy

Strategy for persisting Raft logs

This controls the trade-off between durability guarantees and performance characteristics. The choice impacts both write throughput and recovery behavior after node failures.

flush_policy: FlushPolicy

Flush policy for asynchronous strategies

This controls when log entries are flushed to disk. The choice impacts write performance and durability guarantees.

max_buffered_entries: usize

Maximum number of in-memory log entries to buffer when using async strategies

This acts as a safety valve to prevent memory exhaustion during periods of high write throughput or when disk persistence is slow.

flush_workers: usize

Number of flush worker threads to use for log persistence.

• If set to 0, the system falls back to spawning a new task per flush (legacy behavior, lower latency but less stable under high load).
• If set to a positive number, a worker pool of that size will be created to process flush requests (more stable and efficient under high load).

This parameter allows tuning between throughput and latency depending on workload characteristics.

channel_capacity: usize

Capacity of the internal task channel for flush workers.

• Provides backpressure during high write throughput.
• Prevents unbounded task accumulation in memory when disk I/O is slow.
• Larger values improve throughput at the cost of higher memory usage, while smaller values apply stricter flow control but may reduce parallelism.

Trait Implementations

impl Clone for PersistenceConfig

fn clone(&self) -> PersistenceConfig

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for PersistenceConfig

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

Formats the value using the given formatter.

impl Default for PersistenceConfig

fn default() -> Self

Returns the “default value” for a type.

impl<'de> Deserialize<'de> for PersistenceConfig

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

where __D: Deserializer<'de>,

Deserialize this value from the given Serde deserializer.

impl Serialize for PersistenceConfig

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

where __S: Serializer,

Serialize this value into the given Serde serializer.