Struct IndexReader 

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

Implementations

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

pub async fn from_segment_manager( schema: Arc<Schema>, segment_manager: Arc<SegmentManager<D>>, term_cache_blocks: usize, reload_interval_ms: u64, ) -> Result<Self>

Create a new IndexReader from a segment manager

Centroids are loaded dynamically from metadata on each reload, so the reader always picks up centroids trained after Index::create().

pub async fn from_segment_manager_with_cache_blocks( schema: Arc<Schema>, segment_manager: Arc<SegmentManager<D>>, term_cache_blocks: usize, store_cache_blocks: usize, reload_interval_ms: u64, ) -> Result<Self>

Create an IndexReader with independent term and document-store caches.

pub fn set_reload_interval(&mut self, interval: Duration)

Set reload check interval

pub async fn searcher(&self) -> Result<Arc<Searcher<D>>>

Get current searcher (reloads only if segments changed)

Wait-free read path via ArcSwap::load(). Reload checks are guarded by an AtomicBool to prevent concurrent reloads.

pub async fn reload(&self) -> Result<()>

Force reload reader with fresh snapshot.

Waits for any in-progress reload (from searcher()) to finish, then performs its own reload with the latest segment IDs. This guarantees the reload actually happens — unlike searcher() which silently skips if another reload is in progress.

pub fn schema(&self) -> &Schema

Get schema