Struct SopMetricsCollector 

pub struct SopMetricsCollector { /* private fields */ }

Thread-safe SOP metrics aggregator. Bridges raw SOP audit events into queryable metrics for gate evaluation, health endpoints, and diagnostics.

Implementations

impl SopMetricsCollector

pub fn new() -> SopMetricsCollector

Create an empty collector (cold start).

pub fn shared() -> Arc<SopMetricsCollector>

Process-wide shared collector (production). The engine feeds it (record_run_complete in finish_run) and the SOP tools report from it (sop_status) / feed it (sop_approve), so they observe one set of metrics. Tests use a fresh new() per engine for isolation.

pub fn record_run_complete(&self, run: &SopRun)

Record a terminal run (Completed/Failed/Cancelled). Call after audit.log_run_complete().

pub fn record_approval(&self, sop_name: &str, run_id: &str)

Record a human approval event. Call after the gate resolves (the append-only ledger row is written inside engine.resolve_gate).

pub fn record_capability_executed(&self, sop_name: &str)

EPIC G: record a deterministic capability step execution (global + per-SOP).

pub fn record_timeout_auto_approve(&self, sop_name: &str, run_id: &str)

Record a timeout auto-approval event. Call after the timeout action resolves the gate (the system-attributed gate_resolved ledger row is written inside engine.resolve_gate).

pub async fn rebuild_from_persistence( memory: &dyn Memory, store: &dyn SopRunStore, ) -> Result<SopMetricsCollector, Error>

pub fn get_metric_value(&self, name: &str) -> Option<Value>

pub fn get_metric_value_windowed( &self, name: &str, window: &Duration, ) -> Option<Value>

Resolve a metric with an explicit time window (from Criterion.window_seconds). The name is the base metric name (e.g. "sop.completion_rate"). The window is the Duration from the evaluator.

pub fn snapshot(&self) -> Value

Return a full snapshot of collector state for health/debug purposes.

Trait Implementations

impl Default for SopMetricsCollector

fn default() -> SopMetricsCollector

Returns the “default value” for a type.