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
  • 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

  • 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()