Struct InMemoryTwoPhaseJournal 

pub struct InMemoryTwoPhaseJournal { /* private fields */ }

In-memory 2PC journal (tests and single-process coordinators).

Implementations

impl InMemoryTwoPhaseJournal

pub fn records(&self) -> Vec<TwoPhaseJournalRecord>

Snapshot persisted journal records.

Panics

Panics if the journal lock is poisoned.

Trait Implementations

impl Debug for InMemoryTwoPhaseJournal

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

Formats the value using the given formatter.

impl Default for InMemoryTwoPhaseJournal

fn default() -> InMemoryTwoPhaseJournal

Returns the “default value” for a type.

impl TwoPhaseJournal for InMemoryTwoPhaseJournal

fn on_prepared<'a>( &'a self, tx_id: &'a [u8], step: usize, _total: usize, ) -> Pin<Box<dyn Future<Output = Result<(), TwoPhaseJournalError>> + Send + 'a>>

Persist progress after a successful prepare step.

fn on_committed<'a>( &'a self, tx_id: &'a [u8], step: usize, _total: usize, ) -> Pin<Box<dyn Future<Output = Result<(), TwoPhaseJournalError>> + Send + 'a>>

Persist progress after a successful commit step.

fn on_completed<'a>( &'a self, tx_id: &'a [u8], ) -> Pin<Box<dyn Future<Output = Result<(), TwoPhaseJournalError>> + Send + 'a>>

Mark the transaction fully committed (may delete the journal row).

fn load<'a>( &'a self, tx_id: &'a [u8], ) -> Pin<Box<dyn Future<Output = Result<Option<TwoPhaseJournalRecord>, TwoPhaseJournalError>> + Send + 'a>>

Load coordinator progress for resume.