Struct PerCoreRecoveryManager 

pub struct PerCoreRecoveryManager { /* private fields */ }

Recovery manager for per-core WAL segments.

Implementations

impl PerCoreRecoveryManager

pub fn new( wal_config: PerCoreWalConfig, recovery_config: RecoveryConfig, ) -> Self

Creates a new per-core recovery manager.

pub fn recover(&self) -> Result<PerCoreRecoveredState, PerCoreWalError>

Recovers state from checkpoint + all WAL segments.

Process

1. Load latest checkpoint using RecoveryManager
2. Read all WAL segments from checkpoint positions
3. Merge and sort entries by (epoch, timestamp)
4. Apply merged entries to state

Errors

Returns an error if recovery fails.

pub fn recover_from_positions( &self, positions: &[u64], ) -> Result<PerCoreRecoveredState, PerCoreWalError>

Recovers state using checkpoint-stored per-core WAL positions.

If positions matches num_cores, replay starts from those positions instead of the beginning. On mismatch, falls back to full replay.

Errors

Returns an error if checkpoint recovery or WAL replay fails.

pub fn recover_wal_only(&self) -> Result<Vec<PerCoreWalEntry>, PerCoreWalError>

Recovers state from WAL segments only (no checkpoint).

Errors

Returns an error if reading segments fails.

pub fn repair_all_segments(&self) -> Result<Vec<u64>, PerCoreWalError>

Repairs all WAL segments by truncating at torn writes.

Returns

Returns the valid end positions for each segment.

Errors

Returns an error if repair fails.

pub fn segment_stats(&self) -> Result<Vec<SegmentStats>, PerCoreWalError>

Gets statistics about all WAL segments.

Errors

Returns an error if reading segments fails.

Trait Implementations

impl Debug for PerCoreRecoveryManager

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

Formats the value using the given formatter.