| 99 | /// in `OriginArrayInbound` accepts them on every replica. |
| 100 | #[allow(dead_code)] |
| 101 | pub fn register_schema_on_all(shareds: &[&Arc<SharedState>], array_name: &str) -> Hlc { |
| 102 | let (bytes, schema_hlc) = build_schema_snapshot(array_name); |
| 103 | for shared in shareds { |
| 104 | import_schema_snapshot(shared, array_name, &bytes, schema_hlc); |
| 105 | register_catalog_entry(shared, array_name); |
| 106 | } |
| 107 | schema_hlc |
| 108 | } |
| 109 | |
| 110 | /// Register a single node with a freshly built snapshot. Used by tests that |
| 111 | /// add a new node mid-flight (e.g. snapshot-install learner). Returns the |