diff --git a/milli/src/update/new/channel.rs b/milli/src/update/new/channel.rs index 8226046e6..5c206b5ba 100644 --- a/milli/src/update/new/channel.rs +++ b/milli/src/update/new/channel.rs @@ -12,6 +12,7 @@ use super::StdResult; use crate::index::main_key::{DOCUMENTS_IDS_KEY, WORDS_FST_KEY, WORDS_PREFIXES_FST_KEY}; use crate::update::new::KvReaderFieldId; use crate::update::MergeDeladdCboRoaringBitmaps; +use crate::vector::Embeddings; use crate::{DocumentId, Index}; /// The capacity of the channel is currently in number of messages. @@ -489,6 +490,23 @@ impl DocumentsSender<'_> { } } +pub struct EmbeddingSender<'a>(Option<&'a Sender>); + +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, + ) -> StdResult<(), SendError<()>> { + todo!() + } + + pub fn finish_embedder(embedder_id: u8) {} +} pub enum MergerOperation { ExactWordDocidsMerger(Merger), FidWordCountDocidsMerger(Merger),