Struct ObserverProgressTrackTransaction 

pub struct ObserverProgressTrackTransaction { /* private fields */ }

Ownership barrier between a validated registration and its durable append.

The aggregate is unreachable while the transaction is pending, so no recovery batch can plan an equal-epoch arm against a progress row whose durable append is not yet confirmed. Consuming Self::commit installs the new progress row — after the caller has confirmed the durable append — and consuming Self::abort returns the aggregate byte-for-byte unchanged, conversation still untracked, so a failed append never leaves a live progress row that durable state does not hold.

Implementations

impl ObserverProgressTrackTransaction

pub const fn conversation_id(&self) -> ConversationId

Returns the conversation whose progress row the durable append writes.

pub const fn observer_progress(&self) -> DeliverySeq

Returns the registered hard observer progress for the durable append.

pub fn commit(self) -> ObserverRecoveryAggregate

Installs the registered progress row after a confirmed durable append.

pub fn abort(self) -> ObserverRecoveryAggregate

Cancels a failed durable append; the conversation stays untracked.

Trait Implementations

impl Debug for ObserverProgressTrackTransaction

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

Formats the value using the given formatter.

impl Eq for ObserverProgressTrackTransaction

impl PartialEq for ObserverProgressTrackTransaction

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

Equality operator ==.

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

Inequality operator !=.

impl StructuralPartialEq for ObserverProgressTrackTransaction