Struct ParallelSearcher 

pub struct ParallelSearcher<'a> { /* private fields */ }

Parallel searcher for multi-index queries.

Wraps an IndexRegistry and provides parallel search operations.

Example

use rag_plusplus_core::index::{IndexRegistry, ParallelSearcher, FlatIndex, IndexConfig};

let mut registry = IndexRegistry::new();
registry.register("text", FlatIndex::new(IndexConfig::new(768)))?;
registry.register("code", FlatIndex::new(IndexConfig::new(512)))?;

let searcher = ParallelSearcher::new(&registry);
let results = searcher.search_parallel(&query, 10)?;

Implementations

impl<'a> ParallelSearcher<'a>

pub fn new(registry: &'a IndexRegistry) -> Self

Create a new parallel searcher with default config.

pub fn with_config( registry: &'a IndexRegistry, config: ParallelSearchConfig, ) -> Self

Create a new parallel searcher with custom config.

pub fn search_parallel( &self, query: &[f32], k: usize, ) -> Result<MultiIndexResults>

Search all compatible indexes in parallel.

Arguments

• query - Query vector
• k - Number of results per index

Returns

Results from all indexes with matching dimension.

pub fn search_indexes_parallel( &self, names: &[&str], query: &[f32], k: usize, ) -> Result<MultiIndexResults>

Search specific indexes in parallel.

Arguments

• names - Index names to search
• query - Query vector
• k - Number of results per index

pub fn search_batch( &self, queries: &[Vec<f32>], k: usize, ) -> Vec<Result<MultiIndexResults>>

Batch search: run multiple queries in parallel.

Arguments

• queries - Multiple query vectors
• k - Number of results per query per index

Returns

Results for each query.

pub fn search_indexes_batch( &self, names: &[&str], queries: &[Vec<f32>], k: usize, ) -> Vec<Result<MultiIndexResults>>

Batch search specific indexes.