Struct SimpleLogProcessor

pub struct SimpleLogProcessor<T>
where
    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, SdkLoggerProvider, LogExporter};
use opentelemetry::global;
use opentelemetry_sdk::logs::InMemoryLogExporter;

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

Implementations

impl<T> SimpleLogProcessor<T>

where T: LogExporter,

pub fn new(exporter: T) -> SimpleLogProcessor<T>

Creates a new instance of SimpleLogProcessor.

Trait Implementations

impl<T> Debug for SimpleLogProcessor<T>

where T: Debug + LogExporter,

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

Formats the value using the given formatter.

impl<T> LogProcessor for SimpleLogProcessor<T>

where T: LogExporter,

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

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

fn force_flush(&self) -> Result<(), OTelSdkError>

Force the logs lying in the cache to be exported.

fn shutdown(&self) -> Result<(), OTelSdkError>

Shuts down the processor with default timeout.

fn set_resource(&mut self, resource: &Resource)

Set the resource for the log processor.

fn shutdown_with_timeout(&self, _timeout: Duration) -> Result<(), OTelSdkError>

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.