Struct RecoveryRecord 

pub struct RecoveryRecord {
    pub generation: Generation,
    pub previous_generation: Generation,
    pub known_committed: Offset,
    pub recovery_point: Offset,
    pub discarded_range: Option<Range<Offset>>,
    pub timestamp: Timestamp,
    pub reason: RecoveryReason,
}

Records a recovery event with explicit tracking of any data loss.

Critical for compliance: auditors can see exactly what happened during recovery, including any mutations that were discarded.

Inspired by FoundationDB’s 9-phase recovery with explicit data loss tracking.

Fields

generation: Generation

New generation after recovery.

previous_generation: Generation

Previous generation before recovery.

known_committed: Offset

Last known committed offset before recovery.

recovery_point: Offset

Offset we recovered to.

discarded_range: Option<Range<Offset>>

Range of discarded prepares (if any) - EXPLICIT LOSS TRACKING.

If Some, this range of offsets contained prepared but uncommitted mutations that were discarded during recovery. This is the critical compliance field: it explicitly documents any data loss.

timestamp: Timestamp

When recovery occurred.

reason: RecoveryReason

Why recovery was triggered.

Implementations

impl RecoveryRecord

pub fn new( generation: Generation, previous_generation: Generation, known_committed: Offset, recovery_point: Offset, discarded_range: Option<Range<Offset>>, timestamp: Timestamp, reason: RecoveryReason, ) -> Self

Creates a new recovery record.

Arguments

• generation - The new generation after recovery
• previous_generation - The generation before recovery
• known_committed - Last known committed offset
• recovery_point - The offset we recovered to
• discarded_range - Range of discarded uncommitted prepares, if any
• timestamp - When recovery occurred
• reason - Why recovery was triggered

Preconditions

• generation must be greater than previous_generation
• recovery_point must be <= known_committed

pub fn had_data_loss(&self) -> bool

Returns true if any data was lost during this recovery.

pub fn discarded_count(&self) -> u64

Returns the number of discarded records, if any.

Trait Implementations

impl Clone for RecoveryRecord

fn clone(&self) -> RecoveryRecord

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for RecoveryRecord

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

Formats the value using the given formatter.

impl<'de> Deserialize<'de> for RecoveryRecord

fn deserialize<__D>(__deserializer: __D) -> Result<Self, __D::Error>

where __D: Deserializer<'de>,

Deserialize this value from the given Serde deserializer.

impl PartialEq for RecoveryRecord

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

Tests for self and other values to be equal, and is used by ==.

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

Tests for !=. The default implementation is almost always sufficient, and should not be overridden without very good reason.

impl Serialize for RecoveryRecord

fn serialize<__S>(&self, __serializer: __S) -> Result<__S::Ok, __S::Error>

where __S: Serializer,

Serialize this value into the given Serde serializer.

impl Eq for RecoveryRecord

impl StructuralPartialEq for RecoveryRecord