Struct DistributedSearch

Source

pub struct DistributedSearch { /* private fields */ }

Expand description

Distributed search coordinator

Manages multiple shards and coordinates distributed queries.

Implementations§

Source §

impl DistributedSearch

Source

pub fn new(config: DistributedConfig) -> Self

Create a new distributed search coordinator

Source

pub fn add_shard(&mut self, shard: Shard)

Add a shard to the cluster.

Callers must ensure that each shard registered with this coordinator has a unique ShardId and that the same shard is not added more than once. Adding multiple shards with the same ShardId, or registering the same shard repeatedly, may lead to incorrect query results and statistics.

Source

pub fn shard_count(&self) -> usize

Get number of registered shards

Source

pub fn available_shard_count(&self) -> usize

Get number of available shards

Source

pub fn query( &self, query: &SparseVec, k: usize, ) -> Result<(Vec<DistributedResult>, QueryStats), DistributedError>

Execute a distributed query

Source

pub fn total_queries(&self) -> u64

Get total queries executed

Source

pub fn config(&self) -> &DistributedConfig

Get configuration

Trait Implementations§

Source §

impl Default for DistributedSearch

Source §

fn default() -> DistributedSearch

Returns the “default value” for a type. Read more

Auto Trait Implementations§

§

impl UnwindSafe for DistributedSearch

Blanket Implementations§

Source §

impl<T> Any for T
where T: 'static + ?Sized,

Source §

fn type_id(&self) -> TypeId

Gets the TypeId of self. Read more

Source §

impl<T> Borrow<T> for T
where T: ?Sized,

Source §

fn borrow(&self) -> &T

Immutably borrows from an owned value. Read more

Source §

impl<T> BorrowMut<T> for T
where T: ?Sized,

Source §

fn borrow_mut(&mut self) -> &mut T

Mutably borrows from an owned value. Read more

Source §

impl<T> From<T> for T

Source §

fn from(t: T) -> T

Returns the argument unchanged.

Source §

impl<T, U> Into for T
where U: From<T>,

Source §

fn into(self) -> U

Calls U::from(self).

That is, this conversion is whatever the implementation of From<T> for U chooses to do.

Source §

impl<T> IntoEither for T

Source §

fn into_either(self, into_left: bool) -> Either<Self, Self>

Converts self into a Left variant of Either<Self, Self> if into_left is true. Converts self into a Right variant of Either<Self, Self> otherwise. Read more

Source §

fn into_either_with<F>(self, into_left: F) -> Either<Self, Self>
where F: FnOnce(&Self) -> bool,

Converts self into a Left variant of Either<Self, Self> if into_left(&self) returns true. Converts self into a Right variant of Either<Self, Self> otherwise. Read more

Source §