Struct NoOpComponentContext 

pub struct NoOpComponentContext;

Default no-op component context for tests/examples.

Trait Implementations

impl ComponentContext for NoOpComponentContext

fn resolve_component(&self, _scheme: &str) -> Option<Arc<dyn Component>>

Resolve a component by scheme.

fn resolve_language(&self, _name: &str) -> Option<Arc<dyn Language>>

Resolve a language by name.

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

Access the active metrics collector.

fn platform_service(&self) -> Arc<dyn PlatformService>

Access the active platform service.

fn register_route_health_check( &self, _route_id: &str, _check: Arc<dyn AsyncHealthCheck>, )

fn unregister_route_health_check(&self, _route_id: &str)

fn in_flight_counter(&self) -> Option<Arc<InFlightGauge>>

Context-global gauge of accepted-not-completed exchanges (drainclaim). Production contexts return the gauge installed on every ConsumerContext at consumer start and read by CamelContext::total_in_flight() for the drain verdict. Default None keeps test contexts uncounted.

fn component_metric_levers(&self) -> ComponentMetricsLevers

Snapshot of the [observability.metrics].components configuration — resolved per component by RuntimeObservability::component_metrics(component). The scoped identity (not a global bool) lets an override enable one component series while the coarse components default stays off.

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

Access the active health-check registry.

fn shutdown_token(&self) -> Option<CancellationToken>

Clone of the Runtime-owned shutdown token when this context is bound to one. Producer-side and processor-side code (which has no ConsumerContext) uses it to observe Runtime shutdown. CamelContext overrides this with its shutdown_token(). Default None keeps unbound contexts (tests, examples) out of the shutdown lineage, so callers mint a local root token instead. Callers resolve this per call: CamelContext replaces its shutdown token on every start, so a token captured once goes stale across stop/start.

fn route_id(&self) -> Option<&str>

fn register_current_route_health_check(&self, check: Arc<dyn AsyncHealthCheck>)