Skip to main content

RuntimeObservability

Trait RuntimeObservability 

Source
pub trait RuntimeObservability: Send + Sync {
    // Required methods
    fn metrics(&self) -> Arc<dyn MetricsCollector>;
    fn health(&self) -> Arc<dyn HealthCheckRegistry>;
}
Expand description

Narrow observability surface available to Endpoint consumers and producers.

Implemented blanket for every T: ComponentContext, so CamelContext (the spec’s “DefaultRuntime”) and any test ctx automatically satisfy this trait. Endpoints receive Arc<dyn RuntimeObservability> at create_consumer / create_producer time (per Phase A closure spec).

Send + Sync is mandatory — Endpoints spawn across tokio tasks.

Required Methods§

Source

fn metrics(&self) -> Arc<dyn MetricsCollector>

Active metrics collector. Used for increment_errors(route_id, label) per ADR-0012 categories (b′) and (e).

Source

fn health(&self) -> Arc<dyn HealthCheckRegistry>

Active health-check registry. Used for force_unhealthy_for_route(route_id, name, reason) per ADR-0012 category (g).

Dyn Compatibility§

This trait is dyn compatible.

In older versions of Rust, dyn compatibility was called "object safety".

Implementors§