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

EmbeddingSender stub

Browse Source
This commit is contained in:
Louis Dureuil 2024-10-21 10:35:56 +02:00
parent 124b5c3df8
commit 73e29ee155
No known key found for this signature in database
1 changed files with 18 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

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

@ -12,6 +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::{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.
@ -489,6 +490,23 @@ impl DocumentsSender<'_> {
} }
} }
pub struct EmbeddingSender<'a>(Option<&'a Sender<MergerOperation>>);
impl EmbeddingSender<'_> {
pub fn delete_embeddings(docid: DocumentId, embedder_id: u8) -> StdResult<(), SendError<()>> {
todo!()
}
pub fn set_embeddings(
docid: DocumentId,
embedder_id: u8,
embeddings: Embeddings<f32>,
) -> StdResult<(), SendError<()>> {
todo!()
}
pub fn finish_embedder(embedder_id: u8) {}
}
pub enum MergerOperation { pub enum MergerOperation {
ExactWordDocidsMerger(Merger<File, MergeDeladdCboRoaringBitmaps>), ExactWordDocidsMerger(Merger<File, MergeDeladdCboRoaringBitmaps>),
FidWordCountDocidsMerger(Merger<File, MergeDeladdCboRoaringBitmaps>), FidWordCountDocidsMerger(Merger<File, MergeDeladdCboRoaringBitmaps>),