Struct TwoPhaseCommit 

pub struct TwoPhaseCommit {
    pub phase1_complete: bool,
    pub phase2_complete: bool,
    pub rollback_needed: bool,
}

Two-phase commit strategy for episode storage

Fields

phase1_complete: bool

Phase 1 (cache write) completed

phase2_complete: bool

Phase 2 (durable write) completed

rollback_needed: bool

Rollback is needed

Implementations

impl TwoPhaseCommit

pub fn new() -> Self

Create a new two-phase commit transaction

pub async fn phase1<F, Fut>(&mut self, operation: F) -> Result<()>

where F: FnOnce() -> Fut, Fut: Future<Output = Result<()>>,

Execute phase 1 - write to cache

pub async fn phase2<F, Fut>(&mut self, operation: F) -> Result<()>

where F: FnOnce() -> Fut, Fut: Future<Output = Result<()>>,

Execute phase 2 - write to durable storage

pub async fn rollback<F, Fut>(&mut self, operation: F) -> Result<()>

where F: FnOnce() -> Fut, Fut: Future<Output = Result<()>>,

Rollback phase 1 if phase 2 failed

pub fn is_complete(&self) -> bool

Check if commit is complete

Trait Implementations

impl Debug for TwoPhaseCommit

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

Formats the value using the given formatter.

impl Default for TwoPhaseCommit

fn default() -> Self

Returns the “default value” for a type.