Enum ObserverRecoveryAggregateRestoreError 

pub enum ObserverRecoveryAggregateRestoreError {
    DuplicateProgress {
        conversation_id: ConversationId,
    },
    DuplicateArm {
        conversation_id: ConversationId,
    },
    ArmWithoutProgress {
        conversation_id: ConversationId,
    },
    ArmEpochMismatch {
        conversation_id: ConversationId,
        armed_epoch: ObserverEpoch,
        current_observer_progress: DeliverySeq,
    },
}

Restore-time validation failure for the owned observer-recovery aggregate.

Variants

DuplicateProgress

One conversation appears twice in the durable progress rows.

Fields

conversation_id: ConversationId

Duplicated conversation.

DuplicateArm

One conversation appears twice in the durable arm rows.

Fields

conversation_id: ConversationId

Duplicated conversation.

ArmWithoutProgress

A durable arm names a conversation with no durable progress row.

Fields

conversation_id: ConversationId

Conversation named by the orphaned arm.

ArmEpochMismatch

A durable arm’s epoch differs from its conversation’s progress.

An installed arm is always equal-epoch: it is installed at the exact read progress and fired (removed) by the same mutation that advances progress past it, so any durable disagreement is corruption.

Fields

conversation_id: ConversationId

Conversation whose arm disagrees.

armed_epoch: ObserverEpoch

Epoch stored with the arm.

current_observer_progress: DeliverySeq

Durable hard observer progress.

Trait Implementations

impl Clone for ObserverRecoveryAggregateRestoreError

fn clone(&self) -> ObserverRecoveryAggregateRestoreError

Returns a duplicate of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.

impl Copy for ObserverRecoveryAggregateRestoreError

impl Debug for ObserverRecoveryAggregateRestoreError

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

Formats the value using the given formatter.

impl Eq for ObserverRecoveryAggregateRestoreError

impl PartialEq for ObserverRecoveryAggregateRestoreError

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

Equality operator ==.

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

Inequality operator !=.

impl StructuralPartialEq for ObserverRecoveryAggregateRestoreError