Method maybe_compact

nodedb/src/engine/array/compact.rs:18–45

Run compaction on the array if the picker chooses one. Returns `true` if a merge happened. `audit_retain_ms` is the per-array retention window in milliseconds. `now_ms` is the wall-clock epoch-milliseconds at compaction start. Pass `now_ms = 0` and `audit_retain_ms = None` to disable retention (keeps all tile versions).

(
        &mut self,
        id: &ArrayId,
        audit_retain_ms: Option<i64>,
        now_ms: i64,
    )

    /// Pass `now_ms = 0` and `audit_retain_ms = None` to disable retention
    /// (keeps all tile versions).
    pub fn maybe_compact(
        &mut self,
        id: &ArrayId,
        audit_retain_ms: Option<i64>,
        now_ms: i64,
    ) -> ArrayEngineResult<bool> {
        let plan = match CompactionPicker::pick(self.store(id)?) {
            Some(p) => p,
            None => return Ok(false),
        };
        let store = self.store(id)?;
        let out = CompactionMerger::run(
            store,
            &plan.inputs,
            plan.output_level,
            audit_retain_ms,
            now_ms,
        )?;
        let store = self.store_mut(id)?;
        let removed = out.removed.clone();
        store.replace_segments(&removed, vec![out.segment_ref])?;
        store.persist_manifest()?;
        for old in removed {
            // Best-effort unlink — the manifest is already authoritative.
            let _ = store.unlink_segment(&old);
        }
        Ok(true)
    }
}

#[cfg(test)]