Method export_snapshot

nodedb/src/data/executor/snapshot.rs:12–77

Export the current state of all engines into a serializable snapshot. This captures the complete Data Plane state for this core: redb tables (sparse + edge), in-memory HNSW indexes, and CRDT state.

(&self)

    /// This captures the complete Data Plane state for this core:
    /// redb tables (sparse + edge), in-memory HNSW indexes, and CRDT state.
    pub fn export_snapshot(&self) -> crate::Result<crate::data::snapshot::CoreSnapshot> {
        use crate::data::snapshot::*;

        let sparse_documents: Vec<KvPair> = self
            .sparse
            .export_documents()?
            .into_iter()
            .map(|(k, v)| KvPair { key: k, value: v })
            .collect();

        let sparse_indexes: Vec<KvPair> = self
            .sparse
            .export_indexes()?
            .into_iter()
            .map(|(k, v)| KvPair { key: k, value: v })
            .collect();

        let edges: Vec<TenantKvPair> = self
            .edge_store
            .export_edges()?
            .into_iter()
            .map(|(tid, k, v)| TenantKvPair {
                tenant_id: tid.as_u64(),
                key: k,
                value: v,
            })
            .collect();

        let hnsw_indexes: Vec<HnswSnapshot> = self
            .vector_collections
            .iter()
            .filter_map(|(key, coll)| {
                let checkpoint_bytes =
                    coll.checkpoint_to_bytes(self.vector_checkpoint_kek.as_ref());
                if checkpoint_bytes.is_empty() {
                    return None;
                }
                Some(HnswSnapshot {
                    tenant_id: key.0.as_u64(),
                    collection: key.1.clone(),
                    checkpoint_bytes,
                })
            })
            .collect();

        let crdt_snapshots: Vec<CrdtSnapshot> = self
            .crdt_engines
            .iter()
            .map(|(tid, engine)| {
                Ok(CrdtSnapshot {
                    tenant_id: tid.as_u64(),
                    peer_id: engine.peer_id(),
                    snapshot_bytes: engine.export_snapshot_bytes()?,
                })
            })
            .collect::<crate::Result<Vec<_>>>()?;

        Ok(CoreSnapshot {