Skip to navigation

Struct Open Telemetry LogSubscriber

View as Markdown

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 OpenTelemetryLogSubscriber { /* private fields */ }

Subscriber bound to the SDK’s scope and diagnostic services.

Implementations

impl OpenTelemetryLogSubscriber

impl OpenTelemetryLogSubscriber

new

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

Build the subscriber and bind the SDK runtime automatically.

shutdown_provider

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

Flush and shut down the provider after subscriber delivery settles.

delivery_failure_summary

pub fn delivery_failure_summary(&self) -> Option<String>

Return a summary of unresolved delivery failures, if any.

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<()>

Register with the runtime used by the Rust SDK.

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 OpenTelemetryLogSubscriber

impl Clone for OpenTelemetryLogSubscriber

clone

fn clone(&self) -> OpenTelemetryLogSubscriber

clone_from

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