Struct wasmer_wasix::journal::TransactionJournal

pub struct TransactionJournal<W, R>
where
    W: WritableJournal,
    R: ReadableJournal,
{
    pub(super) tx: TransactionJournalTx<W>,
    pub(super) rx: TransactionJournalRx<R>,
}

Journal which will store the events locally in memory until it is either committed or rolled back

Fields

tx: TransactionJournalTx<W>

rx: TransactionJournalRx<R>

Implementations

impl TransactionJournal<Box<dyn WritableJournal + Send + Sync>, Box<dyn ReadableJournal + Send + Sync>>

pub fn new<J>( inner: J, ) -> TransactionJournal<Box<dyn WritableJournal + Send + Sync>, Box<dyn ReadableJournal + Send + Sync>>

where J: Journal,

Creates a transactional journal which will hold events in memory until the journal is either committed or rolled back

impl<W, R> TransactionJournal<W, R>

where W: WritableJournal, R: ReadableJournal,

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

Trait Implementations

impl<W, R> Debug for TransactionJournal<W, R>

where W: Debug + WritableJournal, R: Debug + ReadableJournal,

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

Formats the value using the given formatter.

impl Journal for TransactionJournal<Box<dyn WritableJournal + Send + Sync>, Box<dyn ReadableJournal + Send + Sync>>

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

Splits the journal into a read and write side

impl<W, R> ReadableJournal for TransactionJournal<W, R>

where W: WritableJournal, R: ReadableJournal,

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<W, R> WritableJournal for TransactionJournal<W, R>

where W: WritableJournal, R: ReadableJournal,

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