Struct PrometheusService 

pub struct PrometheusService { /* private fields */ }

Implementations

impl PrometheusService

pub fn new(addr: SocketAddr) -> Self

pub fn port(&self) -> u16

Returns the actual port the server is listening on (after start())

Returns 0 if the service hasn’t been started yet.

pub fn port_accessor(&self) -> Arc<AtomicU16>

Returns a cloneable accessor for the bound port.

Use this when you need to read the port after the service has been moved into a CamelContext or other container.

pub fn set_health_checker( &mut self, checker: Arc<dyn Fn() -> HealthReport + Send + Sync>, )

Set the health checker closure that will be called to get system health.

The closure should capture a reference to CamelContext’s health_check method.

pub fn health_checker( &self, ) -> Option<Arc<dyn Fn() -> HealthReport + Send + Sync>>

Get a clone of the health checker if one is set.

Trait Implementations

impl Lifecycle for PrometheusService

fn name(&self) -> &str

Service name for logging

fn as_metrics_collector(&self) -> Option<Arc<dyn MetricsCollector>>

Optional: expose MetricsCollector for auto-registration

fn status(&self) -> ServiceStatus

Current status of the service.

fn start<'life0, 'async_trait>( &'life0 mut self, ) -> Pin<Box<dyn Future<Output = Result<(), CamelError>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

Start service (called during CamelContext.start())

fn stop<'life0, 'async_trait>( &'life0 mut self, ) -> Pin<Box<dyn Future<Output = Result<(), CamelError>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

Stop service (called during CamelContext.stop())