Struct EventJournal 

pub struct EventJournal { /* private fields */ }

Implementations

impl EventJournal

pub fn create(path: &Path, max_entries: usize) -> Result<Self>

pub fn create_with_sync_interval( path: &Path, max_entries: usize, sync_interval_entries: usize, ) -> Result<Self>

pub fn resume( path: &Path, max_entries: usize, published_sequence: u64, ) -> Result<Self>

pub fn resume_with_sync_interval( path: &Path, max_entries: usize, published_sequence: u64, sync_interval_entries: usize, ) -> Result<Self>

pub fn append(&mut self, entry: &JournalEntry)

pub fn append_unpublished(&mut self, entry: &JournalEntry)

pub fn append_batch_atomic(&mut self, entries: &[JournalEntry]) -> Result<()>

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

pub fn entries_written(&self) -> usize

pub fn entry_capacity(&self) -> usize

pub fn is_full(&self) -> bool