Struct wasmer_wasix::journal::CountingJournal

pub struct CountingJournal {
    n_cnt: Arc<AtomicUsize>,
    n_size: Arc<AtomicU64>,
}

Journal that counts the size of the entries that are written to it

Fields

n_cnt: Arc<AtomicUsize>

n_size: Arc<AtomicU64>

Implementations

impl CountingJournal

pub fn cnt(&self) -> usize

pub fn size(&self) -> u64

Trait Implementations

impl Clone for CountingJournal

fn clone(&self) -> CountingJournal

Returns a copy of the value.

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

Performs copy-assignment from source.

impl Debug for CountingJournal

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

Formats the value using the given formatter.

impl Default for CountingJournal

fn default() -> CountingJournal

Returns the “default value” for a type.

impl Journal for CountingJournal

fn split( self, ) -> (Box<dyn WritableJournal + Send + Sync>, Box<dyn ReadableJournal + Send + Sync>)

Splits the journal into a read and write side

impl ReadableJournal for CountingJournal

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

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<dyn ReadableJournal + Send + Sync>, Error>

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

impl WritableJournal for CountingJournal

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