Struct wasmer_journal::FilteredJournal

pub struct FilteredJournal<W: WritableJournal, R: ReadableJournal> {
    tx: FilteredJournalTx<W>,
    rx: FilteredJournalRx<R>,
}

Filters out a specific set of journal events and drops the rest, this journal can be useful for restoring to a previous call point but retaining the memory changes (e.g. WCGI runner).

Fields

tx: FilteredJournalTx<W>

rx: FilteredJournalRx<R>

Implementations

impl FilteredJournal<Box<DynWritableJournal>, Box<DynReadableJournal>>

fn new<J>(inner: J, config: FilteredJournalConfig) -> Self

where J: Journal,

pub fn clone_with_inner<J>(&self, inner: J) -> Self

where J: Journal,

impl<W: WritableJournal, R: ReadableJournal> FilteredJournal<W, R>

pub fn into_inner(self) -> RecombinedJournal<W, R>

fn new_split(writer: W, reader: R, config: FilteredJournalConfig) -> Self

Trait Implementations

impl<W: Debug + WritableJournal, R: Debug + ReadableJournal> Debug for FilteredJournal<W, R>

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

Formats the value using the given formatter.

impl Journal for FilteredJournal<Box<DynWritableJournal>, Box<DynReadableJournal>>

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

Splits the journal into a read and write side

impl<W: WritableJournal, R: ReadableJournal> ReadableJournal for FilteredJournal<W, R>

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<W: WritableJournal, R: ReadableJournal> WritableJournal for FilteredJournal<W, R>

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