Struct RocksDBLogStore 

pub struct RocksDBLogStore { /* private fields */ }

RocksDB-based log store implementation

Trait Implementations

impl Debug for RocksDBLogStore

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

Formats the value using the given formatter.

impl Drop for RocksDBLogStore

fn drop(&mut self)

Executes the destructor for this type.

impl LogStore for RocksDBLogStore

fn persist_entries<'life0, 'async_trait>( &'life0 self, entries: Vec<Entry>, ) -> Pin<Box<dyn Future<Output = Result<(), Error>> + Send + 'async_trait>>

where 'life0: 'async_trait, RocksDBLogStore: 'async_trait,

Batch persist entries into disk (optimized for sequential writes)

fn entry<'life0, 'async_trait>( &'life0 self, index: u64, ) -> Pin<Box<dyn Future<Output = Result<Option<Entry>, Error>> + Send + 'async_trait>>

where 'life0: 'async_trait, RocksDBLogStore: 'async_trait,

Get single log entry by index

fn get_entries(&self, range: RangeInclusive<u64>) -> Result<Vec<Entry>, Error>

Get entries in range [start, end] (inclusive)

fn purge<'life0, 'async_trait>( &'life0 self, cutoff_index: LogId, ) -> Pin<Box<dyn Future<Output = Result<(), Error>> + Send + 'async_trait>>

where 'life0: 'async_trait, RocksDBLogStore: 'async_trait,

Remove logs up to specified index

fn truncate<'life0, 'async_trait>( &'life0 self, from_index: u64, ) -> Pin<Box<dyn Future<Output = Result<(), Error>> + Send + 'async_trait>>

where 'life0: 'async_trait, RocksDBLogStore: 'async_trait,

Truncates log from specified index onward

fn flush(&self) -> Result<(), Error>

Optional: Flush pending writes (use with caution)

fn flush_async<'life0, 'async_trait>( &'life0 self, ) -> Pin<Box<dyn Future<Output = Result<(), Error>> + Send + 'async_trait>>

where 'life0: 'async_trait, RocksDBLogStore: 'async_trait,

Optional: Flush pending writes (use with caution)

fn reset<'life0, 'async_trait>( &'life0 self, ) -> Pin<Box<dyn Future<Output = Result<(), Error>> + Send + 'async_trait>>

where 'life0: 'async_trait, RocksDBLogStore: 'async_trait,

fn last_index(&self) -> u64

Get last log index (optimized for frequent access)