Struct CompositeQualityObserver 

pub struct CompositeQualityObserver { /* private fields */ }

Fan-out observer that delegates to multiple backends.

use kmp_observability::quality_observers::*;
let meter = opentelemetry::global::meter("example");
let observer = CompositeQualityObserver::new(vec![
    Box::new(OTelQualityObserver::new(&meter)),
    Box::new(TracingQualityObserver),
]);

Fan-out observer that spawns each adapter on a background task.

Individual adapters run fire-and-forget via tokio::spawn, keeping the gRPC handler hot path free from observer I/O latency.

Implementations

impl CompositeQualityObserver

pub fn new(observers: Vec<Box<dyn QualityMetricsObserver>>) -> Self

Trait Implementations

impl QualityMetricsObserver for CompositeQualityObserver

fn observe( &self, metrics: &BundleQualityMetrics, context: &QualityObservationContext, )

Record a quality metrics observation.