Struct Open Telemetry Subscriber

Generated from cargo doc --no-deps -p nemo-relay-builtins -p nemo-relay-diagnostics -p nemo-relay-logging -p nemo-relay-plugin-host -p nemo-relay-codecs -p nemo-relay -p nemo-relay-runtime -p nemo-relay-model-pricing -p nemo-relay-resource-metrics -p nemo-relay-observability -p nemo-relay-adaptive -p nemo-relay-pii-redaction -p nemo-relay-ffi -p nemo-relay-types -p nemo-relay-plugin -p nemo-relay-worker-proto -p nemo-relay-worker.

pub struct OpenTelemetrySubscriber { /* private fields */ }

Trace subscriber bound to the SDK’s runtime services.

fn host(subscriber: &nemo_relay::exporter::otel::OpenTelemetrySubscriber) {
    let _ = subscriber.host_ref();
}

Implementations

`impl OpenTelemetrySubscriber`

impl OpenTelemetrySubscriber

`new`

pub fn new(config: OpenTelemetryConfig) -> Result<Self>

Build a collector-backed subscriber bound to the SDK runtime.

`new_file_sink`

pub fn new_file_sink(config: OpenTelemetryFileSinkConfig) -> Result<Self>

Build a file subscriber bound to the SDK runtime.

`from_tracer_provider`

pub fn from_tracer_provider(
    provider: SdkTracerProvider,
    instrumentation_scope: impl Into<String>,
) -> Self

Bind an application-owned provider to the SDK runtime.

`from_tracer_provider_with_type`

pub fn from_tracer_provider_with_type(
    provider: SdkTracerProvider,
    instrumentation_scope: impl Into<String>,
    projection: OpenTelemetryType,
) -> Self

Bind a provider with an explicit trace projection.

`from_tracer_provider_with_attribute_mappings`

pub fn from_tracer_provider_with_attribute_mappings<I>(
    provider: SdkTracerProvider,
    instrumentation_scope: impl Into<String>,
    attribute_mappings: I,
) -> Result<Self>where
    I: IntoIterator<Item = OtlpAttributeMapping>,

Bind a provider with typed attribute copies.

`from_tracer_provider_with_options`

pub fn from_tracer_provider_with_options(
    provider: SdkTracerProvider,
    instrumentation_scope: impl Into<String>,
    options: OpenTelemetrySubscriberOptions,
) -> Result<Self>

Bind a provider with composable projection options.

`from_tracer_provider_with_type_and_options`

pub fn from_tracer_provider_with_type_and_options(
    provider: SdkTracerProvider,
    instrumentation_scope: impl Into<String>,
    projection: OpenTelemetryType,
    options: OpenTelemetrySubscriberOptions,
) -> Result<Self>

Bind a typed provider with composable projection options.

`shutdown_provider`

pub fn shutdown_provider(&self) -> Result<()>

Flush and shut down the provider after subscriber delivery settles.

`subscriber`

pub fn subscriber(&self) -> EventSubscriberFn

Return the callback for global or scope-local subscriber registration.

`runtime_diagnostics`

pub fn runtime_diagnostics(&self) -> ExporterRuntimeDiagnostics

Read a bounded snapshot of exporter diagnostics.

`register`

pub fn register(&self, name: &str) -> Result<()>

`deregister`

pub fn deregister(&self, name: &str) -> Result<bool>

Remove a global registration from the runtime.

`force_flush`

pub fn force_flush(&self) -> Result<()>

Wait for accepted events and flush the exporter’s pending output.

`shutdown`

pub fn shutdown(&self) -> Result<()>

Flush pending output and shut down the exporter.

Trait Implementations

`impl Clone for OpenTelemetrySubscriber`

impl Clone for OpenTelemetrySubscriber

`clone`

fn clone(&self) -> OpenTelemetrySubscriber

`clone_from`

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