Struct JournalWriter 

pub struct JournalWriter { /* private fields */ }

An append handle over a single journal file.

The file is opened lazily on first append. The parent directory is fsynced once on the first JournalWriter::sync when the file may have been freshly created, so the file’s existence survives a crash.

Implementations

impl JournalWriter

pub fn new(needs_parent_sync: bool) -> Self

Create a writer. Set needs_parent_sync when the file may not exist yet, so the parent directory is fsynced once the file is created.

pub fn append<C: FrameCodec>( &mut self, path: &Path, record: &C::Record, ) -> Result<()>

Append one record as a framed payload. Does not durably flush; pair with JournalWriter::sync once per batch.

pub fn sync(&mut self, path: &Path) -> Result<()>

fsync the file data, plus the parent directory once if it was freshly created.

Trait Implementations

impl Debug for JournalWriter

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

Formats the value using the given formatter.