Class BatchSpanProcessor.Worker
java.lang.Object
io.opentelemetry.sdk.trace.export.BatchSpanProcessor.Worker
- All Implemented Interfaces:
Runnable
- Enclosing class:
BatchSpanProcessor
-
Field Summary
FieldsModifier and TypeFieldDescriptionprivate boolean
private final Attributes
private final Attributes
private final long
private final AtomicReference
<CompletableResultCode> private final int
private long
private final LongCounter
private final Queue
<ReadableSpan> private final long
private final BlockingQueue
<Boolean> private final SpanExporter
private final AtomicInteger
-
Constructor Summary
ConstructorsModifierConstructorDescriptionprivate
Worker
(SpanExporter spanExporter, MeterProvider meterProvider, long scheduleDelayNanos, int maxExportBatchSize, long exporterTimeoutNanos, Queue<ReadableSpan> queue) -
Method Summary
Modifier and TypeMethodDescriptionprivate void
addSpan
(ReadableSpan span) private void
private void
flush()
private CompletableResultCode
void
run()
private CompletableResultCode
shutdown()
private void
-
Field Details
-
processedSpansCounter
-
droppedAttrs
-
exportedAttrs
-
spanExporter
-
scheduleDelayNanos
private final long scheduleDelayNanos -
maxExportBatchSize
private final int maxExportBatchSize -
exporterTimeoutNanos
private final long exporterTimeoutNanos -
nextExportTime
private long nextExportTime -
queue
-
spansNeeded
-
signal
-
flushRequested
-
continueWork
private volatile boolean continueWork -
batch
-
-
Constructor Details
-
Worker
private Worker(SpanExporter spanExporter, MeterProvider meterProvider, long scheduleDelayNanos, int maxExportBatchSize, long exporterTimeoutNanos, Queue<ReadableSpan> queue)
-
-
Method Details