Struct Open Inference Subscriber
Generated from cargo doc --no-deps -p nemo-relay -p nemo-relay-adaptive -p nemo-relay-ffi.
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)