Struct VersionPruner 

pub struct VersionPruner { /* private fields */ }

Version pruning filter

Determines which versions can be safely garbage collected.

Implementations

impl VersionPruner

pub fn new(config: RetentionConfig) -> Self

pub fn register_snapshot(&self, timestamp: Timestamp)

Register an active snapshot

pub fn unregister_snapshot(&self, timestamp: Timestamp)

Unregister a snapshot

pub fn oldest_snapshot(&self) -> Option<Timestamp>

Get the oldest active snapshot

pub fn can_prune_version( &self, version_timestamp: Timestamp, is_latest: bool, version_index: usize, ) -> bool

Check if a version can be pruned

A version can be pruned if:

1. It’s not the latest version
2. It’s older than max_version_age
3. No active snapshot needs it

A snapshot at time T needs all versions with timestamp <= T (these are the versions that were visible at snapshot time)

pub fn can_collect_tombstone(&self, tombstone_timestamp: Timestamp) -> bool

Check if a tombstone can be collected

A tombstone can be collected only if:

1. It’s older than the grace period
2. No active snapshot needs to see it

pub fn update_time(&self)

Update current time