snowykami/meilisearch
1
0
Fork 0
mirror of https://github.com/meilisearch/meilisearch.git synced 2024-11-25 19:45:05 +08:00
Code Issues Actions 4 Packages Projects Releases Wiki Activity

todo channel

Browse Source
This commit is contained in:
Louis Dureuil 2024-10-28 14:23:02 +01:00
parent af9f96e2af
commit bbb67ae0a8
No known key found for this signature in database
1 changed files with 24 additions and 5 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

29
milli/src/update/new/channel.rs
View File

@ -12,7 +12,7 @@ use super::StdResult;
use crate::index::main_key::{DOCUMENTS_IDS_KEY, WORDS_FST_KEY, WORDS_PREFIXES_FST_KEY}; use crate::index::main_key::{DOCUMENTS_IDS_KEY, WORDS_FST_KEY, WORDS_PREFIXES_FST_KEY};
use crate::update::new::KvReaderFieldId; use crate::update::new::KvReaderFieldId;
use crate::update::MergeDeladdCboRoaringBitmaps; use crate::update::MergeDeladdCboRoaringBitmaps;
use crate::vector::Embeddings; use crate::vector::Embedding;
use crate::{DocumentId, Index}; use crate::{DocumentId, Index};
/// The capacity of the channel is currently in number of messages. /// The capacity of the channel is currently in number of messages.
@ -493,19 +493,38 @@ impl DocumentsSender<'_> {
pub struct EmbeddingSender<'a>(Option<&'a Sender<MergerOperation>>); pub struct EmbeddingSender<'a>(Option<&'a Sender<MergerOperation>>);
impl EmbeddingSender<'_> { impl EmbeddingSender<'_> {
pub fn delete_embeddings(docid: DocumentId, embedder_id: u8) -> StdResult<(), SendError<()>> { pub fn delete(&self, docid: DocumentId, embedder_id: u8) -> StdResult<(), SendError<()>> {
todo!() todo!()
} }
pub fn set_embeddings( pub fn set_vectors(
&self,
docid: DocumentId, docid: DocumentId,
embedder_id: u8, embedder_id: u8,
embeddings: Embeddings<f32>, embeddings: Vec<Embedding>,
) -> StdResult<(), SendError<()>> { ) -> StdResult<(), SendError<()>> {
todo!() todo!()
} }
pub fn finish_embedder(embedder_id: u8) {} pub fn set_vector(
&self,
docid: DocumentId,
embedder_id: u8,
embedding: Embedding,
) -> StdResult<(), SendError<()>> {
todo!()
}
pub fn set_user_provided(
&self,
docid: DocumentId,
embedder_id: u8,
regenerate: bool,
) -> StdResult<(), SendError<()>> {
todo!()
}
pub fn finish(self, embedder_id: u8) {}
} }
pub enum MergerOperation { pub enum MergerOperation {
ExactWordDocidsMerger(Merger<File, MergeDeladdCboRoaringBitmaps>), ExactWordDocidsMerger(Merger<File, MergeDeladdCboRoaringBitmaps>),