Function delete_embedding

src/vector_store.rs:1206–1371

(
    config: &Config,
    hnsw_index: &HNSWIndex,
    version: VersionNumber,
    id: InternalId,
    raw_emb: &RawVectorEmbedding,
)

}

pub fn delete_embedding(
    config: &Config,
    hnsw_index: &HNSWIndex,
    version: VersionNumber,
    id: InternalId,
    raw_emb: &RawVectorEmbedding,
) -> Result<(), WaCustomError> {
    let Some(raw_vec) = &raw_emb.dense_values else {
        return Ok(());
    };

    let quantized_vec = hnsw_index.quantization_metric.read().unwrap().quantize(
        raw_vec,
        *hnsw_index.storage_type.read().unwrap(),
        *hnsw_index.values_range.read().unwrap(),
    )?;

    let mut cur_entry = hnsw_index.get_root_vec();

    let hnsw_params = hnsw_index.hnsw_params.read().unwrap();
    let distance_metric = *hnsw_index.distance_metric.read().unwrap();
    let offset_counter = hnsw_index.offset_counter.read().unwrap();
    let file_id = offset_counter.file_id();

    for level in (0..=hnsw_params.num_layers).rev() {
        let mut skipm = PerformantFixedSet::new(if level == 0 {
            hnsw_params.level_0_neighbors_count
        } else {
            hnsw_params.neighbors_count
        });
        let mut results = traverse_find_nearest(
            config,
            hnsw_index,
            cur_entry,
            &quantized_vec,
            Some(&id),
            None,
            &mut 0,
            &mut skipm,
            &distance_metric,
            false,
            512,
        )?;

        if results.is_empty() {
            cur_entry = unsafe { &*(*cur_entry).latest }
                .try_get_data(&hnsw_index.cache)?
                .get_child();
            continue;
        } else {
            cur_entry = unsafe { &*(*results[0].0).latest }
                .try_get_data(&hnsw_index.cache)?
                .get_child();
        }

        let mut idx = None;

        for (i, (lazy_item_latest_ptr, _)) in results.iter().enumerate() {