(&self, _req: &ArrayShardAggReq)
| 288 | } |
| 289 | |
| 290 | async fn exec_agg(&self, _req: &ArrayShardAggReq) -> Result<Vec<ArrayAggPartial>> { |
| 291 | Ok(self.partials.clone()) |
| 292 | } |
| 293 | |
| 294 | async fn exec_put(&self, req: &ArrayShardPutReq) -> Result<u64> { |
| 295 | Ok(req.wal_lsn) |