Struct swiftide_query::Pipeline

pub struct Pipeline<'stream, S: SearchStrategy = SimilaritySingleEmbedding, T = Pending> { /* private fields */ }

The starting point of a query pipeline

Implementations

impl<'a, S: SearchStrategy> Pipeline<'a, S>

pub fn from_search_strategy(strategy: S) -> Pipeline<'a, S>

Create a query pipeline from a SearchStrategy

Panics

Panics if the inner stream fails to build

impl<'stream: 'static, S> Pipeline<'stream, S, Pending>

where S: SearchStrategy,

pub fn evaluate_with<T: ToOwned<Owned = impl EvaluateQuery + 'stream>>( self, evaluator: T, ) -> Self

Evaluate queries with an evaluator

pub fn then_transform_query<T: ToOwned<Owned = impl TransformQuery + 'stream>>( self, transformer: T, ) -> Pipeline<'stream, S, Pending>

Transform a query into something else, see crate::query_transformers

impl<'stream: 'static, S: SearchStrategy + 'stream> Pipeline<'stream, S, Pending>

pub fn then_retrieve<T: ToOwned<Owned = impl Retrieve<S> + 'stream>>( self, retriever: T, ) -> Pipeline<'stream, S, Retrieved>

Executes the query based on a search query with a retriever

impl<'stream: 'static, S: SearchStrategy> Pipeline<'stream, S, Retrieved>

pub fn then_transform_response<T: ToOwned<Owned = impl TransformResponse + 'stream>>( self, transformer: T, ) -> Pipeline<'stream, S, Retrieved>

Transforms a retrieved query into something else

impl<'stream: 'static, S: SearchStrategy> Pipeline<'stream, S, Retrieved>

pub fn then_answer<T: ToOwned<Owned = impl Answer + 'stream>>( self, answerer: T, ) -> Pipeline<'stream, S, Answered>

Generates an answer based on previous transformations

impl<S: SearchStrategy> Pipeline<'_, S, Answered>

pub async fn query( self, query: impl Into<Query<Pending>>, ) -> Result<Query<Answered>>

Runs the pipeline with a user query, accepts &str as well.

Errors

Errors if any of the transformations failed or no response was found

pub async fn query_all( self, queries: Vec<impl Into<Query<Pending>> + Clone>, ) -> Result<Vec<Query<Answered>>>

Runs the pipeline with multiple queries

Errors

Errors if any of the transformations failed, no response was found, or the stream was closed.

Trait Implementations

impl Default for Pipeline<'_, SimilaritySingleEmbedding>

By default the SearchStrategy is SimilaritySingleEmbedding, which embed the current query and returns a collection of documents.

fn default() -> Self

Returns the “default value” for a type.