Struct SimpleLogProcessor

pub struct SimpleLogProcessor<T: LogExporter> { /* private fields */ }

A LogProcessor designed for testing and debugging purpose, that immediately exports log records as they are emitted. Log records are exported synchronously in the same thread that emits the log record. When using this processor with the OTLP Exporter, the following exporter features are supported:

• grpc-tonic: This requires LoggerProvider to be created within a tokio runtime. Logs can be emitted from any thread, including tokio runtime threads.
• reqwest-blocking-client: LoggerProvider may be created anywhere, but logs must be emitted from a non-tokio runtime thread.
• reqwest-client: LoggerProvider may be created anywhere, but logs must be emitted from a tokio runtime thread.

Example

Using a SimpleLogProcessor

use opentelemetry_sdk::logs::{SimpleLogProcessor, LoggerProvider, LogExporter};
use opentelemetry::global;
use opentelemetry_sdk::logs::InMemoryLogExporter;

let exporter = InMemoryLogExporter::default(); // Replace with an actual exporter
let provider = LoggerProvider::builder()
    .with_simple_exporter(exporter)
    .build();

Trait Implementations

impl<T: Debug + LogExporter> Debug for SimpleLogProcessor<T>

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.

impl<T: LogExporter> LogProcessor for SimpleLogProcessor<T>

fn emit( &self, record: &mut SdkLogRecord, instrumentation: &InstrumentationScope, )

Called when a log record is ready to processed and exported.

fn force_flush(&self) -> OTelSdkResult

Force the logs lying in the cache to be exported.

fn shutdown(&self) -> OTelSdkResult

Shuts down the processor. After shutdown returns the log processor should stop processing any logs. It’s up to the implementation on when to drop the LogProcessor.

fn set_resource(&self, resource: &Resource)

Set the resource for the log processor.