Struct TelemetryInstance 

pub struct TelemetryInstance { /* private fields */ }

Holds initialized tracing/metrics exporters, etc

Implementations

impl TelemetryInstance

pub fn trace_subscriber(&self) -> Option<Arc<dyn Subscriber + Send + Sync>>

Return the trace subscriber associated with the telemetry options/instance. Can be used to manually set the default for a thread or globally using the tracing crate, or with set_trace_subscriber_for_current_thread.

pub fn attach_late_init_metrics(&mut self, meter: Arc<dyn CoreMeter + 'static>)

Some metric meters cannot be initialized until after a tokio runtime has started and after other telemetry has initted (ex: prometheus). They can be attached here.

pub fn get_temporal_metric_meter(&self) -> Option<TemporalMeter>

Returns our wrapper for metric meters, including the metric_prefix from TelemetryOptions. This should be used to initialize clients or for any other temporal-owned metrics. User defined metrics should use Self::get_metric_meter.

pub fn get_metric_meter(&self) -> Option<TemporalMeter>

Returns our wrapper for metric meters, including attaching the service name if enabled.

Trait Implementations

impl CoreTelemetry for TelemetryInstance

fn fetch_buffered_logs(&self) -> Vec<CoreLog>

Each worker buffers logs that should be shuttled over to lang so that they may be rendered with the user’s desired logging library. Use this function to grab the most recent buffered logs since the last time it was called. A fixed number of such logs are retained at maximum, with the oldest being dropped when full.