Struct AsyncJournalWriter 

pub struct AsyncJournalWriter { /* private fields */ }

Implementations

impl AsyncJournalWriter

pub fn new( writer: JournalWriter, batch_interval: Duration, ) -> Result<Self, JournalError>

pub fn with_defaults(writer: JournalWriter) -> Result<Self, JournalError>

pub fn append( &mut self, event: EngineEvent, ) -> Result<EngineEvent, JournalError>

pub fn next_seq(&self) -> u64

pub fn run_id(&self) -> Uuid

pub fn path(&self) -> &Path

pub fn last_record_hash(&self) -> Option<&str>

pub fn shutdown(&mut self) -> Result<(), JournalError>

pub fn into_inner(self) -> Result<JournalWriter, JournalError>

Trait Implementations

impl Drop for AsyncJournalWriter

fn drop(&mut self)

fn pin_drop(self: Pin<&mut Self>)

🔬This is a nightly-only experimental API. (pin_ergonomics)