Struct Open Inference Subscriber

View as Markdown

Generated from cargo doc --no-deps -p nemo-relay -p nemo-relay-adaptive -p nemo-relay-ffi.

1pub struct OpenInferenceSubscriber { /* private fields */ }

OpenInference-backed NeMo Relay subscriber.

Implementations

impl OpenInferenceSubscriber

impl OpenInferenceSubscriber

new

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

Builds a subscriber backed by a new OTLP tracer provider.

from_tracer_provider

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

Builds a subscriber from an already-configured tracer provider.

subscriber

pub fn subscriber(&self) -> EventSubscriberFn

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

register

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

Registers this subscriber globally with the NeMo Relay runtime.

deregister

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

Deregisters a previously-registered global subscriber by name.

force_flush

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

Flushes finished spans through the underlying tracer provider.

shutdown

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

Shuts down the underlying tracer provider.

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

Trait Implementations

impl Clone for OpenInferenceSubscriber

impl Clone for OpenInferenceSubscriber

clone

fn clone(&self) -> OpenInferenceSubscriber

clone_from

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