Struct MultiVectorRetriever 

pub struct MultiVectorRetriever { /* private fields */ }

One type that handles both indexing (multi-rep per parent) and retrieval (parent-doc).

Implementations

impl MultiVectorRetriever

pub fn new( chunks: Arc<RwLock<dyn VectorStore>>, parents: Arc<dyn Docstore>, top_k: usize, ) -> Self

Build with a chunk vector store + parent docstore + top-k.

pub async fn index( &self, parent_id: impl Into<String>, parent: Document, representations: Vec<String>, ) -> Result<()>

Index one parent under multiple text representations.

Trait Implementations

impl Runnable<String, Vec<Document>> for MultiVectorRetriever

fn invoke<'life0, 'async_trait>( &'life0 self, query: String, config: RunnableConfig, ) -> Pin<Box<dyn Future<Output = Result<Vec<Document>>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

One-shot invocation. The hot path.

fn name(&self) -> &str

Friendly name for telemetry / introspection.

fn batch<'life0, 'async_trait>( &'life0 self, inputs: Vec<I>, config: RunnableConfig, ) -> Pin<Box<dyn Future<Output = Result<Vec<O>, CognisError>> + Send + 'async_trait>>

where 'life0: 'async_trait, I: 'static, O: 'static, Self: Sized + Sync + 'async_trait,

Run multiple inputs in parallel. Defaults to buffer_unordered honouring config.max_concurrency.

fn stream<'life0, 'async_trait>( &'life0 self, input: I, config: RunnableConfig, ) -> Pin<Box<dyn Future<Output = Result<RunnableStream<O>, CognisError>> + Send + 'async_trait>>

where 'life0: 'async_trait, Self: Sized + Sync + 'async_trait,

Stream the final output (chunks of O). Default emits one item via invoke — non-streaming runnables are correct without override.

fn stream_events<'life0, 'async_trait>( &'life0 self, input: I, config: RunnableConfig, ) -> Pin<Box<dyn Future<Output = Result<EventStream, CognisError>> + Send + 'async_trait>>

where 'life0: 'async_trait, I: Serialize, O: Serialize, Self: Sized + Sync + 'async_trait,

Stream structured events. Default emits OnStart + OnEnd around an invoke call. Graph engines override to surface per-node events.

fn input_schema(&self) -> Option<Value>

JSON Schema for the input type, if known.

fn output_schema(&self) -> Option<Value>

JSON Schema for the output type, if known.