Struct MockLogStore 

pub struct MockLogStore { /* private fields */ }

Implementations

impl MockLogStore

pub fn checkpoint(&mut self)

Validate that all current expectations for all methods have been satisfied, and discard them.

pub fn new() -> Self

Create a new mock object with no expectations.

This method will not be generated if the real struct already has a new method. However, it will be generated if the struct implements a trait with a new method. The trait’s new method can still be called like <MockX as TraitY>::new

impl MockLogStore

pub fn expect_persist_entries(&mut self) -> &mut Expectation

Create an Expectation for mocking the persist_entries method

pub fn expect_entry(&mut self) -> &mut Expectation

Create an Expectation for mocking the entry method

pub fn expect_get_entries(&mut self) -> &mut Expectation

Create an Expectation for mocking the get_entries method

pub fn expect_purge(&mut self) -> &mut Expectation

Create an Expectation for mocking the purge method

pub fn expect_truncate(&mut self) -> &mut Expectation

Create an Expectation for mocking the truncate method

pub fn expect_flush(&mut self) -> &mut Expectation

Create an Expectation for mocking the flush method

pub fn expect_flush_async(&mut self) -> &mut Expectation

Create an Expectation for mocking the flush_async method

pub fn expect_reset(&mut self) -> &mut Expectation

Create an Expectation for mocking the reset method

pub fn expect_last_index(&mut self) -> &mut Expectation

Create an Expectation for mocking the last_index method

Trait Implementations

impl Debug for MockLogStore

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

Formats the value using the given formatter.

impl Default for MockLogStore

fn default() -> Self

Returns the “default value” for a type.

impl LogStore for MockLogStore

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

where Self: 'async_trait, 'life0: 'async_trait,

Batch persist entries into disk (optimized for sequential writes)

Performance

Implementations should use batch operations and avoid per-entry synchronization. Expected throughput: >100k ops/sec.

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

where Self: 'async_trait, 'life0: '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)

Performance

Should use efficient range scans. Expected latency: <1ms for 10k entries.

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

where Self: 'async_trait, 'life0: '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 Self: 'async_trait, 'life0: '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 Self: 'async_trait, 'life0: 'async_trait,

Optional: Flush pending writes (use with caution)

fn last_index(&self) -> u64

Get last log index (optimized for frequent access)

Implementation note

Should maintain cached value updated on write operations

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

where Self: 'async_trait, 'life0: 'async_trait,