Struct Observability 

pub struct Observability { /* private fields */ }

Production observability configuration and in-process metrics state.

Implementations

impl Observability

pub fn production(service_name: impl Into<String>) -> Self

Creates production observability metadata for a service.

pub fn version(self, version: impl Into<String>) -> Self

Sets the service version label used by tracing and OpenTelemetry config.

pub fn environment(self, environment: impl Into<String>) -> Self

Sets the deployment environment label.

pub fn prometheus(self) -> Self

Enables Prometheus text exposition for configured metrics.

pub fn tracing(self) -> Self

Enables HTTP tracing when this observability object is applied by Nidus.

pub fn otel_from_env(self) -> Self

No-op OpenTelemetry setup when the otel feature is disabled.

pub fn without_http_metrics(self) -> Self

Disables HTTP request metrics.

pub fn without_event_metrics(self) -> Self

Disables observed event metrics.

pub fn without_job_metrics(self) -> Self

Disables observed job metrics.

pub fn without_adapter_instrumentation(self) -> Self

Disables adapter-owned operation instrumentation.

pub fn max_series(self, max_series: usize) -> Self

Caps distinct low-cardinality labels per metric family.

pub fn exclude_route(self, route: impl Into<String>) -> Self

Excludes an HTTP route label from HTTP metrics.

pub fn service_name(&self) -> &str

Returns the service name.

pub fn version_label(&self) -> Option<&str>

Returns the configured service version label.

pub fn environment_label(&self) -> Option<&str>

Returns the configured deployment environment label.

pub fn http_metrics_enabled(&self) -> bool

Returns whether HTTP metrics are enabled.

pub fn prometheus_enabled(&self) -> bool

Returns whether Prometheus exposition is enabled.

pub fn tracing_enabled(&self) -> bool

Returns whether HTTP tracing should be applied by Nidus.

pub fn prometheus_metrics(&self) -> PrometheusMetrics

Returns the underlying HTTP Prometheus collector.

pub fn http_layer(&self) -> MetricsLayer<ObservabilityHttpMetricsHook>

Creates a Tower HTTP metrics layer.

pub fn routes(&self) -> Router

Creates a /metrics router for Prometheus text exposition.

pub fn event_observer(&self) -> ObservabilityEventObserver

Creates an event observer for nidus_events::ObservedEventBus.

pub fn observed_event_bus<T>( &self, ) -> ObservedEventBus<T, ObservabilityEventObserver>

where T: Clone + Send + Sync + 'static,

Creates an observed in-process event bus wired to this observability object.

pub fn job_observer(&self) -> ObservabilityJobObserver

Creates a job observer for nidus_jobs::ObservedJobRunner.

pub fn job_runner(&self) -> ObservedJobRunner<ObservabilityJobObserver>

Creates an observed job runner wired to this observability object.

pub fn adapter_observer(&self) -> ObservabilityAdapterObserver

Creates an adapter observer for Nidus-owned adapter operations.

pub async fn instrument<Fut, T>( &self, operation: impl Into<Cow<'static, str>>, future: Fut, ) -> T

where Fut: Future<Output = T>,

Runs a future inside a named tracing span.

pub fn record_module_graph_validation( &self, status: OperationStatus, duration: Duration, )

Records module graph validation owned by Nidus application bootstrap.

pub fn record_lifecycle_operation( &self, operation: &'static str, status: OperationStatus, duration: Duration, )

Records application lifecycle operation telemetry.

pub fn render_prometheus(&self) -> String

Renders all configured Prometheus metrics.

Trait Implementations

impl Clone for Observability

fn clone(&self) -> Observability

Returns a duplicate of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.

impl Debug for Observability

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.