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<IOTask>)

pub fn start( self, receiver: UnboundedReceiver<IOTask>, log_flush_tx: Option<UnboundedSender<RoleEvent>>, ) -> Arc<Self>

Start the command processor and return an Arc-wrapped instance.

batch_processor runs on a dedicated OS thread (not a tokio worker) so that synchronous RocksDB calls (db.write, flush_wal) never block the async runtime. The thread owns its own new_current_thread runtime — fully independent of the caller’s runtime lifecycle. When the caller’s runtime drops (e.g. at test teardown), the IO thread’s timers and channels are unaffected; it exits cleanly on Shutdown.

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.

fn pin_drop(self: Pin<&mut Self>)

🔬This is a nightly-only experimental API. (pin_ergonomics)

Execute the destructor for this type, but different to Drop::drop, it requires self to be pinned.