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 (ref count hit 0 and marked 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 get_active_segments(&self) -> Vec<String>

Get current segment IDs (excluding those pending deletion)

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

Get the number of active references for a segment

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

Check if a segment is pending deletion

Trait Implementations

impl Default for SegmentTracker

fn default() -> Self

Returns the “default value” for a type.