Struct opentelemetry_sdk::logs::BatchLogProcessor

pub struct BatchLogProcessor<R: RuntimeChannel> { /* private fields */ }

A LogProcessor that asynchronously buffers log records and reports them at a pre-configured interval.

Implementations

impl<R: RuntimeChannel> BatchLogProcessor<R>

pub fn builder<E>(exporter: E, runtime: R) -> BatchLogProcessorBuilder<E, R>

where E: LogExporter,

Create a new batch processor builder

Trait Implementations

impl<R: RuntimeChannel> Debug for BatchLogProcessor<R>

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

Formats the value using the given formatter.

impl<R: RuntimeChannel> LogProcessor for BatchLogProcessor<R>

fn emit(&self, data: &mut LogData)

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

fn force_flush(&self) -> LogResult<()>

Force the logs lying in the cache to be exported.

fn shutdown(&self) -> LogResult<()>

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.