(
edge_store: &crate::engine::graph::edge_store::store::EdgeStore,
edges: &[crate::data::snapshot::TenantKvPair],
)
| 182 | } |
| 183 | |
| 184 | fn restore_edge_data( |
| 185 | edge_store: &crate::engine::graph::edge_store::store::EdgeStore, |
| 186 | edges: &[crate::data::snapshot::TenantKvPair], |
| 187 | ) -> crate::Result<()> { |
| 188 | for kv in edges { |
| 189 | edge_store.put_edge_raw( |
| 190 | nodedb_types::TenantId::new(kv.tenant_id), |
| 191 | &kv.key, |
| 192 | &kv.value, |
| 193 | )?; |
| 194 | } |
| 195 | if !edges.is_empty() { |
| 196 | info!(edges = edges.len(), "edge store data restored"); |
| 197 | } |
| 198 | Ok(()) |
| 199 | } |
| 200 | |
| 201 | fn restore_vector_checkpoints( |
| 202 | data_dir: &Path, |
no test coverage detected