Struct BufferedRaftLog 

pub struct BufferedRaftLog<T>
where
    T: TypeConfig,
{ /* private fields */ }

High-performance buffered Raft log with event-driven architecture

This implementation provides in-memory first access with configurable persistence strategies while ensuring thread safety and avoiding deadlocks.

Key design principles:

• Lock-free reads for 99% of operations
• Event-driven asynchronous processing
• Deadlock prevention through proper error handling
• Memory-efficient batch operations

Implementations

impl<T> BufferedRaftLog<T>

where T: TypeConfig,

pub fn new( node_id: u32, persistence_config: PersistenceConfig, storage: Arc<SOF<T>>, ) -> (Self, UnboundedReceiver<LogCommand>)

pub fn start(self, receiver: UnboundedReceiver<LogCommand>) -> Arc<Self>

Start the command processor and return an Arc-wrapped instance

pub async fn process_flush(&self, indexes: &[u64]) -> Result<()>

Process entries for flush operation Separated to make error handling clearer

pub fn remove_range(&self, range: RangeInclusive<u64>)

Efficient range removal with targeted term index updates O(k + t) where k = number of entries removed, t = number of affected terms

Trait Implementations

impl<T> Debug for BufferedRaftLog<T>

where T: TypeConfig,

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

Formats the value using the given formatter.

impl<T> Drop for BufferedRaftLog<T>

where T: TypeConfig,

fn drop(&mut self)

Executes the destructor for this type.