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 intbufferSizeprivate longdroppedSpansprivate longmaxReferencedSpansprivate java.lang.Objectmonitorprivate longpushedSpansprivate longreferencedSpansprivate longscheduleDelayMillisprivate java.util.Map<java.lang.String,SpanExporter.Handler>serviceHandlersprivate java.util.List<RecordEventsSpanImpl>spans
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description private voidaddSpan(RecordEventsSpanImpl span)private voidexportBatches(java.util.ArrayList<RecordEventsSpanImpl> spansCopy)private voidflush()private longgetDroppedSpans()private longgetPushedSpans()private longgetReferencedSpans()private voidonBatchExport(java.util.List<SpanData> spanDataList)private voidregisterHandler(java.lang.String name, SpanExporter.Handler serviceHandler)voidrun()private voidunregisterHandler(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:
runin 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)
-
-