Package io.opentelemetry.sdk.logs.export
Class BatchLogRecordProcessor.Worker
java.lang.Object
io.opentelemetry.sdk.logs.export.BatchLogRecordProcessor.Worker
- All Implemented Interfaces:
Runnable
- Enclosing class:
BatchLogRecordProcessor
-
Field Summary
FieldsModifier and TypeFieldDescriptionprivate final ArrayList
<LogRecordData> private boolean
private final Attributes
private final Attributes
private final long
private final AtomicReference
<CompletableResultCode> private static final Logger
private final LogRecordExporter
private final AtomicInteger
private final int
private long
private final LongCounter
private final Queue
<ReadWriteLogRecord> private final long
private final BlockingQueue
<Boolean> -
Constructor Summary
ConstructorsModifierConstructorDescriptionprivate
Worker
(LogRecordExporter logRecordExporter, MeterProvider meterProvider, long scheduleDelayNanos, int maxExportBatchSize, long exporterTimeoutNanos, Queue<ReadWriteLogRecord> queue) -
Method Summary
Modifier and TypeMethodDescriptionprivate void
addLog
(ReadWriteLogRecord logData) private void
private void
flush()
private CompletableResultCode
void
run()
private CompletableResultCode
shutdown()
private void
-
Field Details
-
logger
-
processedLogsCounter
-
droppedAttrs
-
exportedAttrs
-
logRecordExporter
-
scheduleDelayNanos
private final long scheduleDelayNanos -
maxExportBatchSize
private final int maxExportBatchSize -
exporterTimeoutNanos
private final long exporterTimeoutNanos -
nextExportTime
private long nextExportTime -
queue
-
logsNeeded
-
signal
-
flushRequested
-
continueWork
private volatile boolean continueWork -
batch
-
-
Constructor Details
-
Worker
private Worker(LogRecordExporter logRecordExporter, MeterProvider meterProvider, long scheduleDelayNanos, int maxExportBatchSize, long exporterTimeoutNanos, Queue<ReadWriteLogRecord> queue)
-
-
Method Details