Struct PrometheusObserver 

pub struct PrometheusObserver { /* private fields */ }

Prometheus-backed observer — exposes metrics for scraping via /metrics.

Implementations

impl PrometheusObserver

pub fn new() -> Self

pub fn encode(&self) -> String

Encode all registered metrics into Prometheus text exposition format.

pub fn shared() -> Arc<Self>

Process-wide singleton handle. All call sites that obtain a Prometheus observer through this function share the same Registry and the same underlying counters, so events recorded by the channel orchestrator and events recorded by the gateway accumulate into the same time series and are visible on a single /metrics scrape.

PrometheusObserver::new() still returns a fresh, isolated instance — kept for tests so parallel test cases don’t see each other’s counts.

Trait Implementations

impl Default for PrometheusObserver

fn default() -> Self

Returns the “default value” for a type.

impl Observer for PrometheusObserver

fn record_event(&self, event: &ObserverEvent)

Record a discrete lifecycle event.

fn record_metric(&self, metric: &ObserverMetric)

Record a numeric metric sample.

fn name(&self) -> &str

Return the human-readable name of this observer backend.

fn as_any(&self) -> &dyn Any

Downcast to Any for backend-specific operations.

fn flush(&self)

Flush any buffered telemetry data to the backend.