(
&mut self,
task: &ExecutionTask,
tid: u64,
op: &SpatialOp,
)
| 10 | |
| 11 | impl CoreLoop { |
| 12 | pub(super) fn dispatch_spatial( |
| 13 | &mut self, |
| 14 | task: &ExecutionTask, |
| 15 | tid: u64, |
| 16 | op: &SpatialOp, |
| 17 | ) -> Response { |
| 18 | match op { |
| 19 | SpatialOp::Insert { |
| 20 | collection, |
| 21 | field, |
| 22 | surrogate, |
| 23 | geometry, |
| 24 | } => self.execute_spatial_insert(task, tid, collection, field, *surrogate, geometry), |
| 25 | |
| 26 | SpatialOp::Delete { |
| 27 | collection, |
| 28 | field, |
| 29 | surrogate, |
| 30 | } => self.execute_spatial_delete(task, tid, collection, field, *surrogate), |
| 31 | |
| 32 | SpatialOp::Scan { |
| 33 | collection, |
| 34 | field, |
| 35 | predicate, |
| 36 | query_geometry, |
| 37 | distance_meters, |
| 38 | attribute_filters, |
| 39 | limit, |
| 40 | projection, |
| 41 | rls_filters, |
| 42 | prefilter, |
| 43 | } => self.execute_spatial_scan( |
| 44 | task, |
| 45 | tid, |
| 46 | collection, |
| 47 | field, |
| 48 | predicate, |
| 49 | query_geometry, |
| 50 | *distance_meters, |
| 51 | attribute_filters, |
| 52 | *limit, |
| 53 | projection, |
| 54 | rls_filters, |
| 55 | prefilter.as_ref(), |
| 56 | ), |
| 57 | } |
| 58 | } |
| 59 | } |
no test coverage detected