inter_compaction/observer.rs

Trait for inter-compaction observability, with default no-op methods for metrics emission.

// Source: https://github.com/xai-org/grok-build | License: Apache-2.0 | Copyright 2023-2026 SpaceXAI
// Provided via justclaw.it.com; keep this notice with the code.
//! Observability seam for inter-compaction.
//!
//! Same rationale as [`crate::intra_compaction::observer`]: the shared
//! pipeline reports events; each harness emits its own metrics. Emission
//! points and label values are part of the behavior contract.

use std::time::Duration;

/// Receives inter-compaction pipeline events. All methods default to no-ops.
pub trait InterCompactionObserver: Send + Sync {
    /// A prior compaction summary was found in the input (re-compaction).
    /// `strategy` is the stable label from `CompactionStrategy::label()`.
    fn on_recompaction(&self, _strategy: &'static str) {}

    /// One 

... (truncated -- full source via MCP)