Package io.opentelemetry.sdk.trace.export

Class BatchSpanProcessor.Worker

java.lang.Object

io.opentelemetry.sdk.trace.export.BatchSpanProcessor.Worker

All Implemented Interfaces:

Runnable

Enclosing class:

BatchSpanProcessor

private static final class BatchSpanProcessor.Worker
extends Object
implements Runnable

Field Summary

Fields

Modifier and Type	Field	Description
private final ArrayList<SpanData>	batch
private boolean	continueWork
private final Attributes	droppedAttrs
private final Attributes	exportedAttrs
private final long	exporterTimeoutNanos
private final AtomicReference<CompletableResultCode>	flushRequested
private final int	maxExportBatchSize
private long	nextExportTime
private final LongCounter	processedSpansCounter
private final Queue<ReadableSpan>	queue
private final long	scheduleDelayNanos
private final BlockingQueue<Boolean>	signal
private final SpanExporter	spanExporter
private final AtomicInteger	spansNeeded

Constructor Summary

Constructors

Modifier	Constructor	Description
private	Worker(SpanExporter spanExporter, MeterProvider meterProvider, long scheduleDelayNanos, int maxExportBatchSize, long exporterTimeoutNanos, Queue<ReadableSpan> queue)

Method Summary

Modifier and Type	Method	Description
private void	addSpan(ReadableSpan span)
private void	exportCurrentBatch()
private void	flush()
private CompletableResultCode	forceFlush()
void	run()
private CompletableResultCode	shutdown()
private void	updateNextExportTime()

Methods inherited from class java.lang.Object

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

Field Details

processedSpansCounter

private final LongCounter processedSpansCounter

droppedAttrs

private final Attributes droppedAttrs

exportedAttrs

private final Attributes exportedAttrs

spanExporter

private final SpanExporter spanExporter

scheduleDelayNanos

private final long scheduleDelayNanos

maxExportBatchSize

private final int maxExportBatchSize

exporterTimeoutNanos

private final long exporterTimeoutNanos

nextExportTime

private long nextExportTime

queue

private final Queue<ReadableSpan> queue

spansNeeded

private final AtomicInteger spansNeeded

signal

private final BlockingQueue<Boolean> signal

flushRequested

private final AtomicReference<CompletableResultCode> flushRequested

continueWork

private volatile boolean continueWork

batch

private final ArrayList<SpanData> batch

Constructor Details

Worker

private Worker(SpanExporter spanExporter,
 MeterProvider meterProvider,
 long scheduleDelayNanos,
 int maxExportBatchSize,
 long exporterTimeoutNanos,
 Queue<ReadableSpan> queue)

Method Details

addSpan

private void addSpan(ReadableSpan span)

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