Struct Milvus

pub struct Milvus<E, M>
where
    E: Embeddings,
    M: Serialize + DeserializeOwned + Send + Sync,
{ /* private fields */ }

Implementations

impl<E, M> Milvus<E, M>

where E: Embeddings, M: Serialize + DeserializeOwned + Send + Sync,

pub fn new( client: Arc<MilvusClient>, collection_name: String, vector_field_name: String, payload_field_name: Option<String>, content_payload_key: Option<String>, metadata_payload_key: Option<String>, embeddings: E, ) -> Self

Trait Implementations

impl<E, M> VectorStore<E, M> for Milvus<E, M>

where E: Embeddings + Send + Sync, M: Send + Sync + Serialize + DeserializeOwned,

type Error = MilvusError<<E as Embeddings>::Error>

fn add_texts<'life0, 'async_trait>( &'life0 self, texts: Vec<String>, ) -> Pin<Box<dyn Future<Output = Result<Vec<String>, Self::Error>> + Send + 'async_trait>>

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

fn add_documents<'life0, 'async_trait>( &'life0 self, documents: Vec<Document<M>>, ) -> Pin<Box<dyn Future<Output = Result<Vec<String>, Self::Error>> + Send + 'async_trait>>

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

fn similarity_search<'life0, 'async_trait>( &'life0 self, query: String, limit: u32, ) -> Pin<Box<dyn Future<Output = Result<Vec<Document<M>>, Self::Error>> + Send + 'async_trait>>

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