Struct SearchPipeline 

pub struct SearchPipeline { /* private fields */ }

Unified search pipeline that orchestrates all RAG components

Implementations

impl SearchPipeline

pub async fn from_config(config: SearchConfig) -> Result<Self>

Create a new search pipeline from configuration

pub async fn default_pipeline() -> Result<Self>

Create a pipeline with default configuration (FastEmbed, InMemory)

pub async fn index_documents( &self, documents: Vec<IndexDocument>, ) -> Result<PipelineIndexStats>

Index documents into the pipeline

This embeds the documents and stores them in both the vector store and BM25 index (if hybrid search is enabled).

pub async fn search( &self, query: &str, top_k: usize, ) -> Result<Vec<PipelineSearchResult>>

Search for documents matching the query

Arguments

• query - Natural language search query
• top_k - Maximum number of results to return

Returns

Ranked list of search results

pub async fn search_with_filter( &self, query: &str, filter: Filter, top_k: usize, ) -> Result<Vec<PipelineSearchResult>>

Search with metadata filtering

pub async fn health_check(&self) -> PipelineHealth

Check health of all pipeline components

pub async fn document_count(&self) -> Result<usize>

Get the number of indexed documents

pub async fn clear(&self) -> Result<()>

Clear all indexed documents

pub fn config(&self) -> &SearchConfig

Get the configuration

pub fn embedding_info(&self) -> (&str, &str, usize)

Get the embedding provider info

pub fn add_known_skill(&mut self, skill_name: &str)

Add known skills to the query processor for better understanding

pub fn add_known_tool(&mut self, tool_name: &str)

Add known tools to the query processor

pub fn add_known_skills( &mut self, skills: impl IntoIterator<Item = impl Into<String>>, )

Add multiple known skills at once

pub fn add_known_tools( &mut self, tools: impl IntoIterator<Item = impl Into<String>>, )

Add multiple known tools at once

pub fn process_query(&self, query: &str) -> ProcessedQuery

Process a query without searching (for debugging)