Struct DistributedIndex 

pub struct DistributedIndex { /* private fields */ }

Heterogeneous local/remote shard coordinator.

Implementations

impl DistributedIndex

pub fn new( dimensions: usize, config: DistributedConfig, ) -> Result<Self, SearchError>

Creates an empty coordinator for fixed-dimensional shards.

Errors

Returns a typed config error.

pub fn push(&mut self, shard: Arc<dyn SearchShard>) -> Result<(), SearchError>

Adds one local or remote shard.

Errors

Returns a dimension mismatch when shard and coordinator differ.

pub fn len(&self) -> usize

pub fn is_empty(&self) -> bool

pub fn search( &self, query: &[f32], count: usize, ) -> Result<Vec<SearchHit>, SearchError>

Fans one query out with bounded workers and keeps the best occurrence of duplicate keys.

Errors

Returns a query, worker, allocation, or shard error.

pub fn search_batch( &self, queries: &[&[f32]], count: usize, ) -> Result<Vec<Vec<SearchHit>>, SearchError>

Searches independent queries while keeping total local threads within worker_budget.

Errors

Returns the first query or shard error in input order.

Trait Implementations

impl Debug for DistributedIndex

fn fmt(&self, formatter: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.