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 status_arc(&self) -> Arc<AtomicU8>

pub fn set_health_source(&mut self, source: Arc<dyn HealthSource>)

pub fn health_source(&self) -> Option<Arc<dyn HealthSource>>

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())

fn as_function_invoker(&self) -> Option<Arc<dyn FunctionInvoker>>