Class SpanExporterImpl.Worker
- java.lang.Object
-
- io.opencensus.implcore.trace.export.SpanExporterImpl.Worker
-
- All Implemented Interfaces:
java.lang.Runnable
- Enclosing class:
- SpanExporterImpl
private static final class SpanExporterImpl.Worker extends java.lang.Object implements java.lang.Runnable
-
-
Field Summary
Fields Modifier and Type Field Description private int
bufferSize
private long
droppedSpans
private long
maxReferencedSpans
private java.lang.Object
monitor
private long
pushedSpans
private long
referencedSpans
private long
scheduleDelayMillis
private java.util.Map<java.lang.String,SpanExporter.Handler>
serviceHandlers
private java.util.List<RecordEventsSpanImpl>
spans
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description private void
addSpan(RecordEventsSpanImpl span)
private void
exportBatches(java.util.ArrayList<RecordEventsSpanImpl> spansCopy)
private void
flush()
private long
getDroppedSpans()
private long
getPushedSpans()
private long
getReferencedSpans()
private void
onBatchExport(java.util.List<SpanData> spanDataList)
private void
registerHandler(java.lang.String name, SpanExporter.Handler serviceHandler)
void
run()
private void
unregisterHandler(java.lang.String name)
-
-
-
Field Detail
-
monitor
private final java.lang.Object monitor
-
spans
private final java.util.List<RecordEventsSpanImpl> spans
-
referencedSpans
private long referencedSpans
-
droppedSpans
private long droppedSpans
-
pushedSpans
private long pushedSpans
-
serviceHandlers
private final java.util.Map<java.lang.String,SpanExporter.Handler> serviceHandlers
-
bufferSize
private final int bufferSize
-
maxReferencedSpans
private final long maxReferencedSpans
-
scheduleDelayMillis
private final long scheduleDelayMillis
-
-
Constructor Detail
-
Worker
private Worker(int bufferSize, Duration scheduleDelay)
-
-
Method Detail
-
addSpan
private void addSpan(RecordEventsSpanImpl span)
-
registerHandler
private void registerHandler(java.lang.String name, SpanExporter.Handler serviceHandler)
-
unregisterHandler
private void unregisterHandler(java.lang.String name)
-
onBatchExport
private void onBatchExport(java.util.List<SpanData> spanDataList)
-
run
public void run()
- Specified by:
run
in interfacejava.lang.Runnable
-
flush
private void flush()
-
getDroppedSpans
private long getDroppedSpans()
-
getReferencedSpans
private long getReferencedSpans()
-
getPushedSpans
private long getPushedSpans()
-
exportBatches
private void exportBatches(java.util.ArrayList<RecordEventsSpanImpl> spansCopy)
-
-