Struct TopRetriever 

pub struct TopRetriever { /* private fields */ }

Cap the result list to n hits after the upstream operator resolves.

Sort by descending score before truncating so callers always get the top-N by score (regardless of how the upstream returned them).

Implementations

impl TopRetriever

pub fn new(inner: Box<dyn Retriever>, n: usize) -> TopRetriever

Trait Implementations

impl Retriever for TopRetriever

fn retrieve<'life0, 'life1, 'async_trait>( &'life0 self, ctx: &'life1 QueryContext, ) -> Pin<Box<dyn Future<Output = Result<Vec<RawHit>, LunarisError>> + Send + 'async_trait>>

where 'life0: 'async_trait, 'life1: 'async_trait, TopRetriever: 'async_trait,

Run the operator against ctx and return the unranked-or-ranked raw hits this operator produces. The downstream stage (combinator or fuse_rrf) decides what to do with them.

fn as_any(&self) -> &(dyn Any + 'static)

Cast this operator to &dyn Any so the RRF routing dispatcher can recover the concrete operator type. Concrete operators override with fn as_any(&self) -> &dyn Any { self }. The default returns a sentinel &() so unknown operators downcast as None (and the dispatcher falls back to client-side RRF instead of misrouting).