Struct Reader 

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

A reader over a fixed journal.

Trait Implementations

impl<E: Context, A: CodecFixedShared> Contiguous for Reader<'_, E, A>

type Item = A

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, pos: u64) -> Result<A, Error>

Read the item at the given position.

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

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

fn try_read_sync(&self, pos: u64) -> Option<A>

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<A>>

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, range: Range<u64>, buffer: NonZeroUsize, read_options: ReadOptions, ) -> Result<impl Stream<Item = Result<Batch<A>, Error>> + Send, Error>

Return a stream of the items in range as Batches of consecutive items, in position order. range must fall within bounds(). An empty range within bounds() yields an empty stream.