Crate espresso_telemetry 

Re-exports

pub use token::Token;

pub use token::TokenParseError;

pub use token::TokenVerifyError;

pub use token::UnauthenticatedToken;

pub use token::load_bls_signing_key;

pub use token::parse_bls_signing_key;

Modules

lifecycle 🔒

In-process OTel logs export plus a periodic Prometheus remote-write push for metrics. Both pipelines share one six-month BLS-BN254 JWT minted from the staking key. Tracing events go through an OTLP/HTTP batch exporter; an externally supplied prometheus::Registry is scraped on a tokio interval and POSTed to /api/v1/write as snappy-compressed protobuf.

push_task 🔒

Periodic push of prometheus::Registry snapshots to a remote-write endpoint. A final flush runs on shutdown. Errors are warn!-logged, never fatal; HTTP 429 triggers one shared ERROR via crate::rate_limit::log_rate_limit_once.

rate_limit 🔒

Single-shot ERROR on the first HTTP 429 from the telemetry proxy, which caps each node’s hourly byte budget. Only the metrics push observes 429 (logs retry via opentelemetry-otlp’s experimental-http-retry); compare_exchange on the shared latch keeps it to one ERROR per process.

remote_write

token

Structs

TelemetryHandle

Owns the OTel logger provider and, optionally, the metrics push task, so both flush on graceful shutdown. Stashes the JWT and endpoint so the push task can be spawned later via TelemetryHandle::attach_metrics_push once the API setup has built the Registry.

TelemetryOptions

Operator-facing telemetry configuration.

Constants

NAME_LABEL 🔒

Functions

build_write_request

encode_to_snappy

format_float 🔒

init

Initialize the OTel logger pipeline and, when registry is Some, spawn the metrics push immediately. Production passes None (the Registry isn’t built yet) and later calls TelemetryHandle::attach_metrics_push; tests pass it directly.

label_pairs_to_labels 🔒

make_bucket_series 🔒

make_series 🔒

named_series 🔒

now_unix_millis 🔒

registry

Read the registry deposited by set_registry. None if no API setup has run yet (tests, CLI tools without the HTTP module).

set_registry

Deposit the Registry. Idempotent: subsequent calls are no-ops, since OnceLock::set returns Err.