Function init_usv_index_for_collection

src/api_service.rs:284–304

creates an USV for a collection

(
    ctx: Arc<AppContext>,
    collection: &Collection,
    quantization_bits: u8,
    sample_threshold: usize,
)

/// creates an USV for a collection
pub async fn init_usv_index_for_collection(
    ctx: Arc<AppContext>,
    collection: &Collection,
    quantization_bits: u8,
    sample_threshold: usize,
) -> Result<Arc<USVIndex>, WaCustomError> {
    let collection_path: Arc<Path> = collection.get_path();
    let index_path = collection_path.join("usv_index");
    fs::create_dir_all(&index_path).map_err(|e| WaCustomError::FsError(e.to_string()))?;

    let index = Arc::new(USVIndex::new(
        index_path.clone(),
        quantization_bits,
        sample_threshold,
    )?);

    ctx.ain_env
        .collections_map
        .insert_usv_index(collection, index.clone())?;
    Ok(index)
}