Struct MetricsServer 

pub struct MetricsServer { /* private fields */ }

HTTP server for exposing Prometheus metrics.

The server provides a /metrics endpoint that returns all registered metrics in Prometheus text exposition format. The server runs asynchronously and can be gracefully shut down.

Implementations

impl MetricsServer

pub fn new(config: MetricsServerConfig, registry: MetricsRegistry) -> Self

Creates a new metrics server with the given configuration and registry.

Arguments

• config - Server configuration (bind address and port)
• registry - Metrics registry to export

Example

use elara_runtime::observability::metrics::MetricsRegistry;
use elara_runtime::observability::metrics_server::{MetricsServer, MetricsServerConfig};

let registry = MetricsRegistry::new();
let config = MetricsServerConfig::default();
let server = MetricsServer::new(config, registry);

pub async fn start(&mut self) -> Result<(), MetricsServerError>

Starts the metrics server.

This method spawns the HTTP server on a background task and returns immediately. The server will continue running until shutdown() is called or the process exits.

Errors

Returns MetricsServerError::BindError if the server cannot bind to the specified address/port (e.g., port already in use).

Example

let registry = MetricsRegistry::new();
let config = MetricsServerConfig::default();
let mut server = MetricsServer::new(config, registry);
 
server.start().await?;

pub async fn shutdown(&mut self)

Shuts down the metrics server gracefully.

This method aborts the server task and waits for it to complete. After shutdown, the server can be restarted by calling start() again.

Example

let mut server = MetricsServer::new(config, registry);
server.start().await?;
 
// ... do work ...
 
server.shutdown().await;

pub fn is_running(&self) -> bool

Returns true if the server is currently running.

pub fn bind_address(&self) -> &str

Returns the configured bind address.

pub fn port(&self) -> u16

Returns the configured port.