Struct wasmer_wasix::journal::CompactingJournalTx

pub struct CompactingJournalTx {
    state: Arc<Mutex<State>>,
    compacting: Arc<Mutex<()>>,
}

Deduplicates memory and stacks to reduce the number of volume of log events sent to its inner capturer. Compacting the events occurs in line as the events are generated

Fields

state: Arc<Mutex<State>>

compacting: Arc<Mutex<()>>

Implementations

impl CompactingJournalTx

pub fn create_filter<J>( &self, inner: J, ) -> FilteredJournal<Box<dyn WritableJournal + Send + Sync>, Box<dyn ReadableJournal + Send + Sync>>

where J: Journal,

pub fn create_split_filter<W, R>( &self, writer: W, reader: R, ) -> FilteredJournal<W, R>

where W: WritableJournal, R: ReadableJournal,

pub fn swap(&self, other: CompactingJournalTx) -> CompactingJournalTx

pub fn compact_to<J>(&self, new_journal: J) -> Result<CompactResult, Error>

where J: Journal,

Compacts the inner journal into a new journal

pub fn replace_inner<J>(&self, inner: J)

where J: Journal,

Trait Implementations

impl Clone for CompactingJournalTx

fn clone(&self) -> CompactingJournalTx

Returns a copy of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.

impl Debug for CompactingJournalTx

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

Formats the value using the given formatter.

impl WritableJournal for CompactingJournalTx

fn write<'a>(&'a self, entry: JournalEntry<'a>) -> Result<LogWriteResult, Error>

Takes in a stream of snapshot log entries and saves them so that they may be restored at a later moment

fn flush(&self) -> Result<(), Error>

Flushes the data to disk or network

fn commit(&self) -> Result<usize, Error>

Commits the transaction Returns the number of events committed

fn rollback(&self) -> Result<usize, Error>

Rolls back the transaction and aborts its changes Returns the number of events rolled back