Class BatchLogRecordProcessor.Worker

java.lang.Object

io.opentelemetry.sdk.logs.export.BatchLogRecordProcessor.Worker

All Implemented Interfaces:

Runnable

Enclosing class:

BatchLogRecordProcessor

private static final class BatchLogRecordProcessor.Worker
extends Object
implements Runnable

Since:

1.27.0

Field Summary

Fields

Modifier and Type	Field	Description
private final ArrayList<LogRecordData>	batch
private boolean	continueWork
private final Attributes	droppedAttrs
private final Attributes	exportedAttrs
private final long	exporterTimeoutNanos
private final AtomicReference<CompletableResultCode>	flushRequested
private static final Logger	logger
private final LogRecordExporter	logRecordExporter
private final AtomicInteger	logsNeeded
private final int	maxExportBatchSize
private long	nextExportTime
private final LongCounter	processedLogsCounter
private final Queue<ReadWriteLogRecord>	queue
private final long	scheduleDelayNanos
private final BlockingQueue<Boolean>	signal

Constructor Summary

Constructors

Modifier	Constructor	Description
private	Worker(LogRecordExporter logRecordExporter, MeterProvider meterProvider, long scheduleDelayNanos, int maxExportBatchSize, long exporterTimeoutNanos, Queue<ReadWriteLogRecord> queue)

Method Summary

Modifier and Type	Method	Description
private void	addLog(ReadWriteLogRecord logData)
private void	exportCurrentBatch()
private void	flush()
private CompletableResultCode	forceFlush()
void	run()
private CompletableResultCode	shutdown()
private void	updateNextExportTime()

Methods inherited from class Object

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

Field Details

logger

private static final Logger logger

processedLogsCounter

private final LongCounter processedLogsCounter

droppedAttrs

private final Attributes droppedAttrs

exportedAttrs

private final Attributes exportedAttrs

logRecordExporter

private final LogRecordExporter logRecordExporter

scheduleDelayNanos

private final long scheduleDelayNanos

maxExportBatchSize

private final int maxExportBatchSize

exporterTimeoutNanos

private final long exporterTimeoutNanos

nextExportTime

private long nextExportTime

queue

private final Queue<ReadWriteLogRecord> queue

logsNeeded

private final AtomicInteger logsNeeded

signal

private final BlockingQueue<Boolean> signal

flushRequested

private final AtomicReference<CompletableResultCode> flushRequested

continueWork

private volatile boolean continueWork

batch

private final ArrayList<LogRecordData> batch

Constructor Details

Worker

private Worker(LogRecordExporter logRecordExporter,
 MeterProvider meterProvider,
 long scheduleDelayNanos,
 int maxExportBatchSize,
 long exporterTimeoutNanos,
 Queue<ReadWriteLogRecord> queue)

Method Details

addLog

private void addLog(ReadWriteLogRecord logData)

run

public void run()

Specified by:

run in interface Runnable

flush

private void flush()

updateNextExportTime

private void updateNextExportTime()

shutdown

private CompletableResultCode shutdown()

forceFlush

private CompletableResultCode forceFlush()

exportCurrentBatch

private void exportCurrentBatch()