Struct SegmentManager 

pub struct SegmentManager<D: DirectoryWriter + 'static> { /* private fields */ }

Segment manager - coordinates segment registration and background merging

This is the central point for:

• Tracking all segment IDs
• Registering new segments (from builds or merges)
• Triggering merge checks when segments are added
• Coordinating background merge tasks

Implementations

impl<D: DirectoryWriter + 'static> SegmentManager<D>

pub fn new( directory: Arc<D>, schema: Arc<Schema>, segment_ids: Vec<String>, merge_policy: Box<dyn MergePolicy>, term_cache_blocks: usize, ) -> Self

Create a new segment manager

pub fn segment_ids(&self) -> Arc<AsyncMutex<Vec<String>>>

Get a clone of the segment_ids Arc for sharing with background tasks

pub async fn get_segment_ids(&self) -> Vec<String>

Get the current segment IDs

pub async fn register_segment(&self, segment_id: String)

Register a new segment and trigger merge check

This is the main entry point for adding segments. It:

1. Adds the segment ID to the list
2. Checks the merge policy and spawns background merges if needed

pub fn pending_merge_count(&self) -> usize

Get the number of pending background merges

pub async fn maybe_merge(&self)

Check merge policy and spawn background merges if needed

pub async fn wait_for_merges(&self)

Wait for all pending merges to complete

pub async fn cleanup_orphan_segments(&self) -> Result<usize>

Clean up orphan segment files that are not registered

This can happen if the process halts after segment files are written but before they are registered in segments.json. Call this on startup to reclaim disk space from incomplete operations.

Returns the number of orphan segments deleted.