Struct wasmer_journal::CompactingJournal

pub struct CompactingJournal {
    tx: CompactingJournalTx,
    rx: CompactingJournalRx,
}

Fields

tx: CompactingJournalTx

rx: CompactingJournalRx

Implementations

impl CompactingJournal

pub fn new<J>(inner: J) -> Result<Self>

where J: Journal,

pub fn create_filter<J>( &self, inner: J, ) -> FilteredJournal<Box<DynWritableJournal>, Box<DynReadableJournal>>

where J: Journal,

Creates a filter jounral which will write all its events to an inner journal

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

where W: WritableJournal, R: ReadableJournal,

Creates a filter journal which will write all its events to writer and readers supplied

impl CompactingJournal

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

where J: Journal,

Compacts the inner journal into a new journal

pub fn into_split(self) -> (CompactingJournalTx, CompactingJournalRx)

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

Trait Implementations

impl Debug for CompactingJournal

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

Formats the value using the given formatter.

impl Journal for CompactingJournal

fn split(self) -> (Box<DynWritableJournal>, Box<DynReadableJournal>)

Splits the journal into a read and write side

impl ReadableJournal for CompactingJournal

fn read(&self) -> Result<Option<LogReadResult<'_>>>

Returns a stream of snapshot objects that the runtime will use to restore the state of a WASM process to a previous moment in time

fn as_restarted(&self) -> Result<Box<DynReadableJournal>>

Resets the journal so that reads will start from the beginning again

impl WritableJournal for CompactingJournal

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

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<()>

Flushes the data to disk or network

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

Commits the transaction Returns the number of events committed

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

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