use crate::qdrant::*;
#[derive(Clone)]
pub struct TextIndexParamsBuilder {
pub(crate) tokenizer: Option<i32>,
pub(crate) lowercase: Option<Option<bool>>,
pub(crate) min_token_len: Option<Option<u64>>,
pub(crate) max_token_len: Option<Option<u64>>,
pub(crate) on_disk: Option<Option<bool>>,
pub(crate) stopwords: Option<Option<StopwordsSet>>,
pub(crate) phrase_matching: Option<Option<bool>>,
pub(crate) stemmer: Option<Option<StemmingAlgorithm>>,
pub(crate) ascii_folding: Option<Option<bool>>,
pub(crate) enable_hnsw: Option<Option<bool>>,
}
impl TextIndexParamsBuilder {
pub fn new(tokenizer: TokenizerType) -> Self {
let mut builder = Self::create_empty();
builder.tokenizer = Some(tokenizer.into());
builder
}
pub fn tokenizer(self, value: i32) -> Self {
let mut new = self;
new.tokenizer = Option::Some(value);
new
}
pub fn lowercase(self, value: bool) -> Self {
let mut new = self;
new.lowercase = Option::Some(Option::Some(value));
new
}
pub fn min_token_len(self, value: u64) -> Self {
let mut new = self;
new.min_token_len = Option::Some(Option::Some(value));
new
}
pub fn max_token_len(self, value: u64) -> Self {
let mut new = self;
new.max_token_len = Option::Some(Option::Some(value));
new
}
pub fn on_disk(self, value: bool) -> Self {
let mut new = self;
new.on_disk = Option::Some(Option::Some(value));
new
}
pub fn stopwords_language(self, language: String) -> Self {
let mut new = self;
let stopwords_set = StopwordsSet {
languages: vec![language],
custom: vec![],
};
new.stopwords = Some(Some(stopwords_set));
new
}
pub fn stopwords(self, stopwords_set: StopwordsSet) -> Self {
let mut new = self;
new.stopwords = Some(Some(stopwords_set));
new
}
pub fn phrase_matching(self, phrase_matching: bool) -> Self {
let mut new = self;
new.phrase_matching = Some(Some(phrase_matching));
new
}
pub fn snowball_stemmer(self, language: String) -> Self {
let mut new: TextIndexParamsBuilder = self;
let stemmer = StemmingAlgorithm {
stemming_params: Some(stemming_algorithm::StemmingParams::Snowball(
SnowballParams { language },
)),
};
new.stemmer = Some(Some(stemmer));
new
}
pub fn stemmer(self, stemming_params: stemming_algorithm::StemmingParams) -> Self {
let mut new = self;
let stemmer = StemmingAlgorithm {
stemming_params: Some(stemming_params),
};
new.stemmer = Some(Some(stemmer));
new
}
pub fn ascii_folding(self, value: bool) -> Self {
let mut new = self;
new.ascii_folding = Option::Some(Option::Some(value));
new
}
pub fn enable_hnsw(self, value: bool) -> Self {
let mut new = self;
new.enable_hnsw = Option::Some(Option::Some(value));
new
}
fn build_inner(self) -> Result<TextIndexParams, TextIndexParamsBuilderError> {
Ok(TextIndexParams {
tokenizer: match self.tokenizer {
Some(value) => value,
None => {
return Result::Err(core::convert::Into::into(
::derive_builder::UninitializedFieldError::from("tokenizer"),
));
}
},
lowercase: self.lowercase.unwrap_or_default(),
min_token_len: self.min_token_len.unwrap_or_default(),
max_token_len: self.max_token_len.unwrap_or_default(),
on_disk: self.on_disk.unwrap_or_default(),
stopwords: self.stopwords.unwrap_or_default(),
phrase_matching: self.phrase_matching.unwrap_or_default(),
stemmer: self.stemmer.unwrap_or_default(),
ascii_folding: self.ascii_folding.unwrap_or_default(),
enable_hnsw: self.enable_hnsw.unwrap_or_default(),
})
}
fn create_empty() -> Self {
Self {
tokenizer: Default::default(),
lowercase: Default::default(),
min_token_len: Default::default(),
max_token_len: Default::default(),
on_disk: Default::default(),
stopwords: Default::default(),
phrase_matching: Default::default(),
stemmer: Default::default(),
ascii_folding: Default::default(),
enable_hnsw: Default::default(),
}
}
}
impl From<TextIndexParamsBuilder> for TextIndexParams {
fn from(value: TextIndexParamsBuilder) -> Self {
value.build_inner().unwrap_or_else(|_| {
panic!(
"Failed to convert {0} to {1}",
"TextIndexParamsBuilder", "TextIndexParams"
)
})
}
}
impl TextIndexParamsBuilder {
pub fn build(self) -> TextIndexParams {
self.build_inner().unwrap_or_else(|_| {
panic!(
"Failed to build {0} into {1}",
"TextIndexParamsBuilder", "TextIndexParams"
)
})
}
}
#[non_exhaustive]
#[derive(Debug)]
pub enum TextIndexParamsBuilderError {
UninitializedField(&'static str),
ValidationError(String),
}
impl std::fmt::Display for TextIndexParamsBuilderError {
fn fmt(&self, f: &mut std::fmt::Formatter) -> std::fmt::Result {
match self {
Self::UninitializedField(field) => {
write!(f, "`{field}` must be initialized")
}
Self::ValidationError(error) => write!(f, "{error}"),
}
}
}
impl std::error::Error for TextIndexParamsBuilderError {}
impl From<derive_builder::UninitializedFieldError> for TextIndexParamsBuilderError {
fn from(error: derive_builder::UninitializedFieldError) -> Self {
Self::UninitializedField(error.field_name())
}
}
impl From<String> for TextIndexParamsBuilderError {
fn from(error: String) -> Self {
Self::ValidationError(error)
}
}