Struct JournalConsumer 

pub struct JournalConsumer { /* private fields */ }

Implementations

impl JournalConsumer

pub fn open(path: &Path) -> Result<Self>

pub fn open_unverified(path: &Path) -> Result<Self>

pub fn seek_to_end(&mut self) -> Result<()>

pub fn seek_to_sequence(&mut self, sequence: u64) -> Result<()>

pub const fn last_sequence(&self) -> u64

pub fn poll(&mut self) -> Option<JournalEntry>

pub fn try_poll(&mut self) -> Result<Option<JournalEntry>, JournalReadError>

pub fn published_sequence(&self) -> u64