Struct Reader 

pub struct Reader<'a, E: Context, V: Codec> { /* private fields */ }

A reader over a variable journal.

Trait Implementations

impl<E: Context, V: CodecShared> Contiguous for Reader<'_, E, V>

type Item = V

The type of items stored in the journal.

fn bounds(&self) -> Range<u64>

Returns [start, end) with a guaranteed stable pruning boundary.

async fn read(&self, position: u64) -> Result<V, Error>

Read the item at the given position.

async fn read_many(&self, positions: &[u64]) -> Result<Vec<V>, Error>

Read multiple items at the given positions, which must be strictly increasing.

fn try_read_sync(&self, position: u64) -> Option<V>

Read an item if it can be done synchronously (e.g. without I/O), returning None otherwise. Decode failures surface as None and the async read path reports the error.

fn try_read_many_sync(&self, positions: &[u64]) -> Vec<Option<V>>

Probe multiple strictly increasing positions, serving those that can be read synchronously (e.g. from a page cache) and returning one slot per position. Positions that require I/O, fail to decode, or fall outside bounds() decline to None. The async read paths are the sole error authority for declined positions.

async fn replay( &self, start_pos: u64, buffer: NonZeroUsize, ) -> Result<impl Stream<Item = Result<(u64, V), Error>> + Send, Error>

Return a stream of all items starting from start_pos, bounded by bounds().