Package io.opentelemetry.sdk.logs

Class MultiLogRecordProcessor

java.lang.Object

io.opentelemetry.sdk.logs.MultiLogRecordProcessor

All Implemented Interfaces:

LogRecordProcessor, Closeable, AutoCloseable

final class MultiLogRecordProcessor
extends Object
implements LogRecordProcessor

Implementation of LogRecordProcessor that forwards all logs to a list of LogRecordProcessors.

Field Summary

Fields

Modifier and Type	Field	Description
private final AtomicBoolean	isShutdown
private final List<LogRecordProcessor>	logRecordProcessors

Constructor Summary

Constructors

Modifier	Constructor	Description
private	MultiLogRecordProcessor(List<LogRecordProcessor> logRecordProcessorsList)

Method Summary

Modifier and Type	Method	Description
(package private) static LogRecordProcessor	create(List<LogRecordProcessor> logRecordProcessorsList)	Create a new MultiLogRecordProcessor.
CompletableResultCode	forceFlush()	Process all log records that have not yet been processed.
void	onEmit(Context context, ReadWriteLogRecord logRecord)	Called when a Logger LogRecordBuilder.emit()s a log record.
CompletableResultCode	shutdown()	Shutdown the log processor.

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Methods inherited from interface io.opentelemetry.sdk.logs.LogRecordProcessor

close

Field Details

logRecordProcessors

private final List<LogRecordProcessor> logRecordProcessors

isShutdown

private final AtomicBoolean isShutdown

Constructor Details

MultiLogRecordProcessor

private MultiLogRecordProcessor(List<LogRecordProcessor> logRecordProcessorsList)

Method Details

create

static LogRecordProcessor create(List<LogRecordProcessor> logRecordProcessorsList)

Create a new MultiLogRecordProcessor.

Parameters:

logRecordProcessorsList - list of log processors to forward logs to

Returns:

a multi log processor instance

onEmit

public void onEmit(Context context,
 ReadWriteLogRecord logRecord)

Description copied from interface: LogRecordProcessor

Called when a Logger LogRecordBuilder.emit()s a log record.

Specified by:

onEmit in interface LogRecordProcessor

Parameters:

context - the context set via LogRecordBuilder.setContext(Context), or Context.current() if not explicitly set

logRecord - the log record

shutdown

public CompletableResultCode shutdown()

Description copied from interface: LogRecordProcessor

Shutdown the log processor.

Specified by:

shutdown in interface LogRecordProcessor

Returns:

result

forceFlush

public CompletableResultCode forceFlush()

Description copied from interface: LogRecordProcessor

Process all log records that have not yet been processed.

Specified by:

forceFlush in interface LogRecordProcessor

Returns:

result