(store: &EdgeStore)
| 73 | /// Used by test harnesses that insert under one tenant at a time. |
| 74 | #[cfg(test)] |
| 75 | pub fn rebuild_from_store(store: &EdgeStore) -> crate::Result<CsrIndex> { |
| 76 | use std::collections::hash_map::Entry; |
| 77 | |
| 78 | let mut sharded = rebuild_sharded_from_store_as_of(store, None)?; |
| 79 | let tid = sharded |
| 80 | .iter() |
| 81 | .map(|(tid, _)| *tid) |
| 82 | .next() |
| 83 | .unwrap_or_else(|| TenantId::new(0)); |
| 84 | match sharded.entry(tid) { |
| 85 | Entry::Occupied(entry) => Ok(entry.remove()), |
| 86 | Entry::Vacant(_) => Ok(CsrIndex::new()), |
| 87 | } |
| 88 | } |