pub enum PersistenceStrategy {
DiskFirst,
MemFirst,
}Expand description
Defines how Raft log entries are persisted and accessed.
All strategies use a configurable FlushPolicy to control when memory contents
are flushed to disk, affecting write latency and durability guarantees.
Note: Both strategies now fully load all log entries from disk into memory at startup.
The in-memory SkipMap serves as the primary data structure for reads in all modes.
Variants§
DiskFirst
Disk-first persistence strategy.
-
Write path: On append, the log entry is first written to disk. Only after a successful disk write is it acknowledged and stored in the in-memory
SkipMap. -
Read path: Reads are always served from the in-memory
SkipMap. -
Startup behavior: All log entries are loaded from disk into memory at startup, ensuring consistent access speed regardless of disk state.
-
Suitable for systems prioritizing strong durability while still providing in-memory performance for reads.
MemFirst
Memory-first persistence strategy.
-
Write path: On append, the log entry is first written to the in-memory
SkipMapand acknowledged immediately. Disk persistence happens asynchronously in the background, governed byFlushPolicy. -
Read path: Reads are always served from the in-memory
SkipMap. -
Startup behavior: All log entries are loaded from disk into memory at startup, the same as
DiskFirst. -
Suitable for systems that favor lower write latency and faster failover, while still retaining a disk-backed log for crash recovery.
Trait Implementations§
Source§impl Clone for PersistenceStrategy
impl Clone for PersistenceStrategy
Source§fn clone(&self) -> PersistenceStrategy
fn clone(&self) -> PersistenceStrategy
1.0.0 · Source§fn clone_from(&mut self, source: &Self)
fn clone_from(&mut self, source: &Self)
source. Read moreSource§impl Debug for PersistenceStrategy
impl Debug for PersistenceStrategy
Source§impl<'de> Deserialize<'de> for PersistenceStrategy
impl<'de> Deserialize<'de> for PersistenceStrategy
Source§fn deserialize<__D>(__deserializer: __D) -> Result<Self, __D::Error>where
__D: Deserializer<'de>,
fn deserialize<__D>(__deserializer: __D) -> Result<Self, __D::Error>where
__D: Deserializer<'de>,
Source§impl PartialEq for PersistenceStrategy
impl PartialEq for PersistenceStrategy
Source§impl Serialize for PersistenceStrategy
impl Serialize for PersistenceStrategy
impl StructuralPartialEq for PersistenceStrategy
Auto Trait Implementations§
impl Freeze for PersistenceStrategy
impl RefUnwindSafe for PersistenceStrategy
impl Send for PersistenceStrategy
impl Sync for PersistenceStrategy
impl Unpin for PersistenceStrategy
impl UnwindSafe for PersistenceStrategy
Blanket Implementations§
Source§impl<T> BorrowMut<T> for Twhere
T: ?Sized,
impl<T> BorrowMut<T> for Twhere
T: ?Sized,
Source§fn borrow_mut(&mut self) -> &mut T
fn borrow_mut(&mut self) -> &mut T
Source§impl<T> CloneToUninit for Twhere
T: Clone,
impl<T> CloneToUninit for Twhere
T: Clone,
Source§impl<T> Instrument for T
impl<T> Instrument for T
Source§fn instrument(self, span: Span) -> Instrumented<Self>
fn instrument(self, span: Span) -> Instrumented<Self>
Source§fn in_current_span(self) -> Instrumented<Self>
fn in_current_span(self) -> Instrumented<Self>
Source§impl<T> IntoRequest<T> for T
impl<T> IntoRequest<T> for T
Source§fn into_request(self) -> Request<T>
fn into_request(self) -> Request<T>
T in a tonic::Request