Struct OpenTelemetrySubscriber 

pub struct OpenTelemetrySubscriber { /* private fields */ }

OpenTelemetry-backed NeMo Flow subscriber.

Implementations

impl OpenTelemetrySubscriber

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

Builds a subscriber backed by a new OTLP tracer provider.

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

Builds a subscriber from an already-configured tracer provider.

pub fn subscriber(&self) -> EventSubscriberFn

Returns the raw NeMo Flow subscriber callback for custom registration flows.

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

Registers this subscriber globally with the NeMo Flow runtime.

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

Deregisters a previously-registered global subscriber by name.

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

Flushes finished spans through the underlying tracer provider.

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

Shuts down the underlying tracer provider.

Call deregister(...) first if the subscriber is still registered with NeMo Flow.

Trait Implementations

impl Clone for OpenTelemetrySubscriber

fn clone(&self) -> OpenTelemetrySubscriber

Returns a duplicate of the value.

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

Performs copy-assignment from source.