(
assigner: Option<&SurrogateAssigner>,
collection: &str,
pk_bytes: &[u8],
)
| 44 | } |
| 45 | |
| 46 | fn assign_or_zero( |
| 47 | assigner: Option<&SurrogateAssigner>, |
| 48 | collection: &str, |
| 49 | pk_bytes: &[u8], |
| 50 | ) -> crate::Result<nodedb_types::Surrogate> { |
| 51 | match assigner { |
| 52 | Some(a) => a.assign(collection, pk_bytes), |
| 53 | None => Ok(nodedb_types::Surrogate::ZERO), |
| 54 | } |
| 55 | } |
| 56 | |
| 57 | /// Convert a ReplicatedWrite back into a PhysicalPlan for Data Plane execution. |
| 58 | fn to_physical_plan( |
no test coverage detected