Struct ObserverProgressRetireTransaction 

pub struct ObserverProgressRetireTransaction { /* private fields */ }

Ownership barrier between a validated retirement and its durable append.

The aggregate is unreachable while the transaction is pending, so no arm can be installed on the conversation between the check and the removal. Consuming Self::commit removes the progress row after the caller has confirmed the durable retire row; consuming Self::abort returns the aggregate unchanged.

Implementations

impl ObserverProgressRetireTransaction

pub const fn conversation_id(&self) -> ConversationId

Returns the conversation whose retire row the durable append writes.

pub fn commit(self) -> ObserverRecoveryAggregate

Removes the conversation’s progress row after a confirmed durable append.

pub fn abort(self) -> ObserverRecoveryAggregate

Cancels a failed durable append; the row stays.

Trait Implementations

impl Debug for ObserverProgressRetireTransaction

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

Formats the value using the given formatter.

impl Eq for ObserverProgressRetireTransaction

impl PartialEq for ObserverProgressRetireTransaction

fn eq(&self, other: &Self) -> bool

Equality operator ==.

fn ne(&self, other: &Rhs) -> bool

Inequality operator !=.

impl StructuralPartialEq for ObserverProgressRetireTransaction