Struct TelemetryHandle 

pub struct TelemetryHandle {
    logger_provider: Option<SdkLoggerProvider>,
    log_filter: String,
    jwt: String,
    endpoint: String,
    metrics_interval: Duration,
    metrics_push: Option<MetricsPushHandle>,
    metrics_enabled: bool,
    metrics_external_labels: Vec<Label>,
    rate_limit_warned: Arc<AtomicBool>,
    telemetry_log_filter: Arc<String>,
}

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.

Fields

logger_provider: Option<SdkLoggerProvider>

None when only metrics are enabled (logs pipeline disabled).

log_filter: String

jwt: String

endpoint: String

metrics_interval: Duration

metrics_push: Option<MetricsPushHandle>

metrics_enabled: bool

When false, attach_metrics_push is a no-op.

metrics_external_labels: Vec<Label>

Labels stamped onto every pushed TimeSeries (e.g. service, instance), mirroring the OTel resource attributes so the aggregator partitions logs and metrics consistently.

rate_limit_warned: Arc<AtomicBool>

Latch flipped on the first HTTP 429 from the metrics push, so the operator-facing ERROR is logged once per process across push ticks. The logs pipeline retries 429s via opentelemetry-otlp’s built-in experimental-http-retry and does not surface them here.

telemetry_log_filter: Arc<String>

log_filter embedded verbatim in the rate-limit ERROR so operators see their active filter.

Implementations

impl TelemetryHandle

pub fn tracing_layer<S>(&self) -> Option<impl Layer<S> + Send + Sync + 'static>

where S: Subscriber + for<'a> LookupSpan<'a>,

Layer bridging tracing events into the OTLP exporter, filtered by log_filter. None when the logs pipeline is disabled.

pub fn attach_metrics_push(&mut self, registry: Arc<Registry>)

Wrapper over [attach_metrics_push_buffered] that emits setup warnings directly, for callers that already have a subscriber installed.

fn attach_metrics_push_buffered( &mut self, registry: Arc<Registry>, deferred: &mut Vec<String>, )

Spawn the periodic metrics push on its own thread. Idempotent: no-op if already attached or if metrics are disabled. Setup warnings buffer into deferred so init can replay them after a subscriber is installed.

pub fn shutdown(self)

Flush the push thread, then shut down the OTel logger provider. Best-effort; failures are logged, never bubbled. Both joins run through join_bounded (the provider shutdown can deadlock on a current-thread runtime).

Trait Implementations

impl Debug for TelemetryHandle

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

Formats the value using the given formatter.