Struct SegmentTracker 

pub struct SegmentTracker { /* private fields */ }

Tracks segment references and pending deletions

Implementations

impl SegmentTracker

pub fn new() -> Self

Create a new segment tracker

pub fn register(&self, segment_id: &str)

Register a new segment (called when segment is committed)

pub fn acquire(&self, segment_ids: &[String]) -> Vec<String>

Acquire references to a set of segments (called when taking a snapshot) Returns the segment IDs that were successfully acquired

pub fn release(&self, segment_ids: &[String]) -> Vec<SegmentId>

Release references to a set of segments (called when snapshot is dropped) Returns segment IDs that are now ready for deletion

pub fn mark_for_deletion(&self, segment_ids: &[String]) -> Vec<SegmentId>

Mark segments for deletion (called after merge completes) Segments with ref count 0 are returned immediately for deletion Segments with refs > 0 are queued for deletion when refs are released

pub fn is_pending_deletion(&self, segment_id: &str) -> bool

Check if a segment is pending deletion

pub fn is_deletion_protected(&self, segment_id: &str) -> bool

Whether files must remain protected from orphan sweeping.

This covers both segments waiting for readers and segments whose last reader released them but whose asynchronous filesystem deletion has not completed yet. Moving between those states is atomic under the tracker lock, so the sweeper cannot race the deletion callback.

pub fn complete_deletion(&self, segment_ids: &[SegmentId])

Finish the scheduled-deletion lifecycle after the filesystem attempt.

Failed deletes are also completed here so a later orphan sweep can retry them instead of protecting the files forever.

pub fn ref_count(&self, segment_id: &str) -> usize

Get the number of active references for a segment

Trait Implementations

impl Default for SegmentTracker

fn default() -> Self

Returns the “default value” for a type.