Struct OpenTelemetrySink 

pub struct OpenTelemetrySink<L> { /* private fields */ }

A sink with a OpenTelemetry provider as the target.

It takes a SdkLoggerProvider from the upstream opentelemetry_sdk crate, the relevant settings should be configured there.

Note that when configuring SdkLoggerProvider, you can use the batch exporter to gain better throughput via its built-in asynchronous implementation. If you choose to do so, combining OpenTelemetrySink with AsyncPoolSink is no longer necessary.

Implementations

impl OpenTelemetrySink<()>

pub fn builder() -> OpenTelemetryBuilder<NotSet>

Gets a builder of TelegramSink with default parameters:

Parameter	Default Value
level_filter	All
formatter	FullFormatter (!time !level !source_location !eol)
error_handler	ErrorHandler::default()
provider	must be specified

Examples found in repository

examples/usage.rs (line 43)

fn setup_logger(
    provider: &opentelemetry_sdk::logs::SdkLoggerProvider,
) -> Result<(), Box<dyn StdError>> {
    let sink = Arc::new(OpenTelemetrySink::builder().provider(provider).build()?);

    let logger = spdlog::default_logger().fork_with(|logger| {
        logger.set_level_filter(LevelFilter::All);
        logger.sinks_mut().push(sink);
        // Now the new logger has 3 sinks: stdout + stderr + OpenTelemetry
        //                                 ^^^^^^^^^^^^^^^
        //                                 forked from the default logger
        Ok(())
    })?;
    spdlog::set_default_logger(logger);
    Ok(())
}

Trait Implementations

impl<L> GetSinkProp for OpenTelemetrySink<L>

fn prop(&self) -> &SinkProp

Gets the SinkProp from a sink.

impl<L> Sink for OpenTelemetrySink<L>

where L: OtelLogger + Send + Sync,

fn log(&self, record: &Record<'_>) -> Result<()>

Logs a record.

fn flush(&self) -> Result<()>

Flushes any buffered records.

fn should_log(&self, level: Level) -> bool

Determines if a log message with the specified level would be logged.

fn flush_on_exit(&self) -> Result<(), Error>

Flushes any buffered records at program exit.