Struct LogIterator 

pub struct LogIterator { /* private fields */ }

An iterator over a Data file.

The LogIterator acts as an active reader over the log, pulling messages from the log and decoding them, while maintaining a cursor to ensure that superflous reads are not performed when a read limit is provided via end_position.

Implementations

impl LogIterator

pub fn new(reader: BufReader<File>, cursor: u64, end_position: u64) -> Self

Constructs a new LogIterator instance.

pub async fn next(&mut self) -> Result<Option<Message>>

Attempts to decode and retrieve the next message from the reader. Returns Option::None if there are no more messages to decode.

Errors

Returns std::io::ErrorKind::UnexpectedEof if the an unexpected end-of-file is encountered due to a partially committed or corrupted message.

Trait Implementations

impl Debug for LogIterator

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

Formats the value using the given formatter.