Skip to main content

ParallelSearcher

Struct ParallelSearcher

pub struct ParallelSearcher { /* private fields */ }

Expand description

Long-lived fan-out searcher (2g.2): T pinned snapshot readers, each owning one contiguous id slice of the fingerprint keyspace. Send the same query to all slices, merge survivors, exact-rescore on reader 0.

Implementations§

impl ParallelSearcher

pub fn nearest( &mut self, q: &[f32], k: usize, metric: Metric, oversample: usize, ) -> Result<Vec<(u64, f32)>>

&mut self: each spawned thread takes EXCLUSIVE &mut access to its own reader – Graph is deliberately not Sync (single-threaded cells), and this is the honest way to say “one reader per thread”.

Auto Trait Implementations§

impl !RefUnwindSafe for ParallelSearcher

impl !Sync for ParallelSearcher

impl !UnwindSafe for ParallelSearcher

impl Freeze for ParallelSearcher

impl Send for ParallelSearcher

impl Unpin for ParallelSearcher

impl UnsafeUnpin for ParallelSearcher

Blanket Implementations§

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

fn type_id(&self) -> TypeId

Gets the TypeId of self. Read more

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

fn borrow(&self) -> &T

Immutably borrows from an owned value. Read more

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

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

Mutably borrows from an owned value. Read more

impl<T> From<T> for T

fn from(t: T) -> T

Returns the argument unchanged.

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

fn into(self) -> U

Calls U::from(self).

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

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

type Error = !

The type returned in the event of a conversion error.

fn try_from(value: U) -> Result<T, !>

Performs the conversion.

impl<T, U> TryInto<U> for T
where U: TryFrom<T>,

type Error = <U as TryFrom<T>>::Error

The type returned in the event of a conversion error.

fn try_into(self) -> Result<U, <U as TryFrom<T>>::Error>

Performs the conversion.