Crate rocketmq_observability 

Re-exports

pub use metrics::dashboard::DashboardStorageBackend;

pub use metrics::dashboard::DashboardStorageFailureLabel;

pub use metrics::dashboard::DashboardStorageMetricsRecorder;

pub use metrics::dashboard::DashboardStorageOperation;

pub use metrics::dashboard::DashboardStorageOperationResult;

pub use metrics::dashboard::DashboardStorageResult;

pub use metrics::labels::MetricLabelPolicy;

pub use metrics::labels::METRIC_LABEL_SENTINEL;

Modules

logs

metrics

semantic

statistics

stats

trace

Structs

Attribute

ConsoleLogConfig

FileLogConfig

FileLogLayer

LogFilterHandle

LogFilterInputs

LogFilterReloadRequest

LogFilterResolver

LoggingConfig

LoggingGuard

LoggingOverrideConfig

LoggingOverrides

LogsOverrides

MetricAttributes

Attributes recorded with a metric measurement.

MetricsOverrides

MetricsRuntimePolicy

Immutable, non-sensitive metrics settings captured from the final resolved configuration.

NonBlockingLogConfig

ObservabilityCompiledFeaturesV1

ObservabilityConfig

ObservabilityError

Opaque observability error backed by one canonical shared error.

ObservabilityFailureDetail

A string-only diagnostic retained as a typed source.

ObservabilityOverrides

ObservabilitySignalStatusV1

ObservabilityStatusHandle

ObservabilityStatusViewV1

Authenticated, sanitized status for an initialized observability runtime.

ObservabilitySubscriberStatusV1

OtlpOverrides

PrometheusOverrides

ReloadConfig

ResolvedLogFilter

RuntimeDiagnosticsEndpointConfig

Fail-closed configuration for the protected runtime diagnostics listener.

RuntimeDiagnosticsEndpointHandle

Bound address of the lifecycle-owned diagnostics listener.

RuntimeDiagnosticsService

One owned, idempotently initialized sampler and optional HTTP listener.

RuntimeDiagnosticsSources

Caller-owned, read-only component sources and a retained shutdown summary.

RuntimeDiagnosticsStarted

SamplingGate

SubscriberInstallStatus

TelemetryBootstrapConfig

TelemetryEnvironmentSpec

Service-specific environment variable names understood by telemetry resolution.

TelemetryEnvironmentValues

Raw process environment values used by the deterministic telemetry resolver.

TelemetryHandle

Cloneable telemetry capability injected into business components.

TelemetryOutageQueue

A count-and-byte bounded queue for exporter adapters.

TelemetryOutageShutdownReport

Final state produced when an outage queue drains or reaches its absolute deadline.

TelemetryQueueLimits

Count and byte limits for an exporter outage queue.

TelemetryQueueSnapshot

Current queue and lifetime counters.

TelemetryRecorder

Lightweight recorder scoped to one business component.

TelemetryResolution

Fully resolved telemetry configuration and its validated process metadata.

TelemetryRuntimeGuard

TelemetryShutdownReport

TracePolicy

Immutable per-handle tracing and message-correlation policy.

TracesConfig

TracesOverrides

Enums

LogExporterType

LogFilterSource

LogFormat

LogRotation

LogsExporter

MetricsExporter

MetricsExporterType

ObservabilityOperation

The closed observability operation retained outside catalog policy.

ObservabilityStatusValueV1

OtlpProtocol

RuntimeDiagnosticsMode

Explicitly selects diagnostic work, independently of compiled features.

StandardOtlpEnvironmentStatus

SubscriberInstallPolicy

TelemetryDropReason

Reason a telemetry record was dropped before export.

TelemetryEnqueueOutcome

Result of non-blocking telemetry admission.

TelemetryQueueConfigError

Invalid telemetry outage queue configuration.

TelemetryState

Current state of a telemetry handle’s runtime-owned lifecycle.

TraceExporter

TraceExporterType

Constants

BROKER_METER_SCOPE

Fixed instrumentation scope for broker metrics.

CLIENT_METER_SCOPE

Fixed instrumentation scope for client metrics.

CONTROLLER_METER_SCOPE

Fixed instrumentation scope for controller metrics.

DASHBOARD_METER_SCOPE

Fixed instrumentation scope for dashboard operations metrics.

DEFAULT_EXPORT_TIMEOUT_MILLIS

Default maximum duration of one collector export attempt.

DEFAULT_LOG_FILTER

DEFAULT_MAX_EXPORT_BATCH_ITEMS

Default maximum number of records returned in one exporter batch.

DEFAULT_MAX_QUEUE_BYTES

Default maximum estimated bytes admitted during a collector outage.

DEFAULT_MAX_QUEUE_ITEMS

Default maximum number of telemetry records admitted during a collector outage.

DEFAULT_MAX_RECORD_BYTES

Default maximum size of one admitted telemetry record.

DEFAULT_SCHEDULED_DELAY_MILLIS

Default interval before a partial exporter batch is flushed.

DEFAULT_SHUTDOWN_TIMEOUT_MILLIS

Default total deadline for telemetry provider shutdown.

MCP_METER_SCOPE

Fixed instrumentation scope for MCP metrics.

NAMESRV_METER_SCOPE

Fixed instrumentation scope for NameServer metrics.

OTEL_EXPORTER_OTLP_ENDPOINT

OTEL_EXPORTER_OTLP_PROTOCOL

PROXY_METER_SCOPE

Fixed instrumentation scope for proxy metrics.

RUNTIME_DIAGNOSTICS_ALLOW_INSECURE_HTTP_ENV

RUNTIME_DIAGNOSTICS_BIND_ADDR_ENV

RUNTIME_DIAGNOSTICS_ENDPOINT_SCHEMA

RUNTIME_DIAGNOSTICS_MODE_ENV

RUNTIME_DIAGNOSTICS_PATH

RUNTIME_DIAGNOSTICS_SAMPLE_INTERVAL_SECONDS_ENV

RUNTIME_DIAGNOSTICS_SCOPE

RUNTIME_DIAGNOSTICS_TOKEN_FILE_ENV

RUNTIME_METADATA_TARGETS_PATH

Protected, process-shared metadata registry occupancy without target names.

RUNTIME_METER_SCOPE

Fixed instrumentation scope for runtime lifecycle and scheduler metrics.

SRE_CONNECTOR_METER_SCOPE

Fixed instrumentation scope for AI SRE Connector metrics.

SRE_CONTROL_PLANE_METER_SCOPE

Fixed instrumentation scope for AI SRE Control Plane metrics.

STORE_METER_SCOPE

Fixed instrumentation scope for store metrics.

TIERED_STORE_METER_SCOPE

Fixed instrumentation scope for tiered-store metrics.

TRACEPARENT

TRACESTATE

TRANSPORT_METER_SCOPE

Fixed instrumentation scope for transport metrics.

Traits

RuntimeDiagnosticsDataProvider

Bounded, synchronous access to diagnostics owned by the business component.

Functions

apply_standard_otlp_environment

Applies the standard process-wide OTLP endpoint and protocol variables.

apply_standard_otlp_environment_values

Applies caller-supplied standard OTLP environment values without reading process state.

base_attributes

init_observability

Initializes observability providers and keeps the legacy best-effort subscriber install behavior.

init_observability_with_service_context

Initializes observability with a lifecycle owner for runtime-backed exporters.

install_global

install_global_with_filter

install_global_with_filter_and_service_context

Installs process telemetry with a resolved filter and an explicit task owner.

install_global_with_service_context

Installs process telemetry with an explicit owner for runtime-backed exporters.

normalize_and_validate

Validates the final cross-signal observability configuration.

read_rust_log

Reads the process-level RUST_LOG override without silently discarding a non-Unicode value.

reserve_telemetry_flush_lease

Reserves one blocking submission for a final telemetry flush owned by service_context.

resolve_telemetry_from_env

Resolves telemetry using values read from the current process environment.

resolve_telemetry_values

Resolves defaults, file overrides, and caller-supplied environment values.

start_runtime_diagnostics_endpoint

Starts a protected diagnostics listener using an explicit configuration.

start_runtime_diagnostics_endpoint_from_env

Starts the optional protected endpoint and its owned metrics sampler.

start_runtime_diagnostics_endpoint_from_env_with_telemetry

Starts the opt-in runtime diagnostics endpoint and records snapshots into the caller-owned telemetry pipeline.

Type Aliases

ObservabilityResult

Result returned by observability operations.