kmp-domain 0.18.1

Domain model of the Kernel Memory Protocol: aggregates, value objects, repositories and projections, with no IO
Documentation 
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28

use crate::value_objects::BundleQualityMetrics;

/// Context metadata for a quality metrics observation.
#[derive(Debug, Clone)]
pub struct QualityObservationContext {
    /// The RPC that produced this observation (e.g. "GetContext", "GetContextPath").
    pub rpc: String,
    /// Root node ID of the queried graph.
    pub root_node_id: String,
    /// Role for which the bundle was rendered.
    pub role: String,
    /// Memory revision that produced the rendered bundle, when the caller has
    /// one. Exemplars use it to resolve a point without guessing from time.
    pub revision: Option<u64>,
}

/// Port for observing quality metrics produced by the rendering pipeline.
///
/// Adapters implement this to push metrics to different backends:
/// OTel histograms, Loki structured logs, Prometheus push gateway, etc.
///
/// The kernel calls [`Self::observe`] after every successful render. Adapters
/// must be non-blocking — an adapter that blocks on I/O should buffer
/// internally and flush asynchronously.
pub trait QualityMetricsObserver: Send + Sync {
    /// Record a quality metrics observation.
    fn observe(&self, metrics: &BundleQualityMetrics, context: &QualityObservationContext);
}