Struct PointInTimeRestore 

pub struct PointInTimeRestore {
    pub target_timestamp: u64,
    pub wal_dir: PathBuf,
}

Driver for point-in-time recovery.

Usage:

let pit = PointInTimeRestore::new(target_ts, wal_dir);
let base = pit.find_base_checkpoint()?;
let entries = pit.replay_wal_to_timestamp(base.as_ref())?;
// Apply entries to the index...

Fields

target_timestamp: u64

Target Unix-epoch timestamp in seconds.

wal_dir: PathBuf

Directory that contains the WAL files.

Implementations

impl PointInTimeRestore

pub fn new(target_timestamp_secs: u64, wal_dir: PathBuf) -> Self

Create a new driver.

target_timestamp_secs is seconds since Unix epoch; callers that have a std::time::SystemTime should convert with system_time.duration_since(UNIX_EPOCH).unwrap_or_default().as_secs().

pub fn find_base_checkpoint(&self) -> Result<Option<CheckpointRef>>

Find the latest CheckpointRef whose timestamp is ≤ target_timestamp.

Returns None when no checkpoint precedes the target (the caller should treat that as “start from an empty base”).

pub fn replay_wal_to_timestamp( &self, base: Option<&CheckpointRef>, ) -> Result<Vec<WalEntry>>

Replay WAL entries that fall between base.sequence_number (exclusive) and target_timestamp (inclusive).

When base is None (no prior checkpoint) all entries up to target_timestamp are returned.