Execute the purge plan against `store`. Returns the total number of tile-version drops across all segment rewrites. The caller is responsible for any tracing / audit records.
(store: &mut ArrayStore, plan: PurgePlan)
| 36 | /// Returns the total number of tile-version drops across all segment |
| 37 | /// rewrites. The caller is responsible for any tracing / audit records. |
| 38 | pub fn execute(store: &mut ArrayStore, plan: PurgePlan) -> Result<u64, ArrayError> { |
| 39 | let mut total_dropped: u64 = 0; |
| 40 | |
| 41 | for action in plan.segment_actions { |
| 42 | let dropped = rewrite_segment(store, &action)?; |
| 43 | total_dropped += dropped; |
| 44 | } |
| 45 | |
| 46 | Ok(total_dropped) |
| 47 | } |
| 48 | |
| 49 | /// Intermediate output from the read phase — everything needed to decide |
| 50 | /// what to write and then perform the manifest swap. |
no test coverage detected