Struct JournalReader 

pub struct JournalReader<R: Read> { /* private fields */ }

Implementations

impl<R: Read> JournalReader<R>

pub fn new(source: R, max_record_size: u32) -> Self

pub fn max_record_size(&self) -> u32

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

pub fn position(&self) -> Option<ReaderPosition>

pub fn next_seq(&self) -> u64

pub fn saw_torn_tail(&self) -> bool

pub fn verify_position( source: R, max_record_size: u32, expected: ReaderPosition, ) -> Result<Self>

pub fn from_positioned( source: R, max_record_size: u32, position: ReaderPosition, ) -> Result<Self>

impl<R: Read + Seek> JournalReader<R>

pub fn resume( source: R, max_record_size: u32, position: ReaderPosition, ) -> Result<Self>

Trait Implementations

impl<R: Debug + Read> Debug for JournalReader<R>

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