Function restore_vector_checkpoints

nodedb/src/storage/snapshot_executor.rs:201–229

(
    data_dir: &Path,
    _core_id: usize,
    hnsw_indexes: &[crate::data::snapshot::HnswSnapshot],
)

}

fn restore_vector_checkpoints(
    data_dir: &Path,
    _core_id: usize,
    hnsw_indexes: &[crate::data::snapshot::HnswSnapshot],
) -> crate::Result<u64> {
    if hnsw_indexes.is_empty() {
        return Ok(0);
    }

    let ckpt_dir = data_dir.join("vector-ckpt");
    // no-objectstore: HNSW checkpoints are mmap'd locally for query hot path.
    std::fs::create_dir_all(&ckpt_dir).map_err(crate::Error::Io)?;

    let mut total_vectors = 0u64;
    for idx in hnsw_indexes {
        let key = format!("{}:{}:emb", idx.tenant_id, idx.collection);
        let ckpt_path = ckpt_dir.join(format!("{key}.ckpt"));
        let tmp_path = ckpt_dir.join(format!("{key}.ckpt.tmp"));
        nodedb_wal::segment::atomic_write_fsync(&tmp_path, &ckpt_path, &idx.checkpoint_bytes)
            .map_err(crate::Error::Wal)?;
        total_vectors += 1;
    }

    info!(
        collections = hnsw_indexes.len(),
        "vector checkpoints restored"
    );
    Ok(total_vectors)
}

fn restore_crdt_checkpoints(
    data_dir: &Path,