Class SpanExporterImpl

java.lang.Object

io.opencensus.trace.export.SpanExporter

io.opencensus.implcore.trace.export.SpanExporterImpl

public final class SpanExporterImpl
extends SpanExporter

Implementation of the SpanExporter.

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
private static class	SpanExporterImpl.ReportDroppedSpans
private static class	SpanExporterImpl.ReportPushedSpans
private static class	SpanExporterImpl.ReportReferencedSpans
private static final class	SpanExporterImpl.Worker

Nested classes/interfaces inherited from class SpanExporter

SpanExporter.Handler

Field Summary

Fields

Modifier and Type	Field	Description
private static final DerivedLongCumulative	droppedSpans
private static final Logger	logger
private static final DerivedLongCumulative	pushedSpans
private static final DerivedLongGauge	referencedSpans
private final SpanExporterImpl.Worker	worker
private final Thread	workerThread

Constructor Summary

Constructors

Modifier	Constructor	Description
private	SpanExporterImpl(SpanExporterImpl.Worker worker)

Method Summary

Modifier and Type	Method	Description
void	addSpan(RecordEventsSpanImpl span)	Adds a Span to the exporting service.
(package private) static SpanExporterImpl	create(int bufferSize, Duration scheduleDelay)	Constructs a SpanExporterImpl that exports the SpanData asynchronously.
(package private) void	flush()
(package private) long	getDroppedSpans()
(package private) long	getPushedSpans()
(package private) long	getReferencedSpans()
(package private) Thread	getServiceExporterThread()
void	registerHandler(String name, SpanExporter.Handler handler)	Registers a new service handler that is used by the library to export SpanData for sampled spans (see TraceOptions.isSampled()).
(package private) void	shutdown()
void	unregisterHandler(String name)	Unregisters the service handler with the provided name.

Methods inherited from class SpanExporter

getNoopSpanExporter

Methods inherited from class Object

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

Field Details

logger

private static final Logger logger

droppedSpans

private static final DerivedLongCumulative droppedSpans

pushedSpans

private static final DerivedLongCumulative pushedSpans

referencedSpans

private static final DerivedLongGauge referencedSpans

worker

private final SpanExporterImpl.Worker worker

workerThread

private final Thread workerThread

Constructor Details

SpanExporterImpl

private SpanExporterImpl(SpanExporterImpl.Worker worker)

Method Details

create

static SpanExporterImpl create(int bufferSize,
 Duration scheduleDelay)

Constructs a SpanExporterImpl that exports the SpanData asynchronously.

Starts a separate thread that wakes up every scheduleDelay and exports any available spans data. If the number of buffered SpanData objects is greater than bufferSize then the thread wakes up sooner.

Parameters:

bufferSize - the size of the buffered span data.

scheduleDelay - the maximum delay.

addSpan

public void addSpan(RecordEventsSpanImpl span)

Adds a Span to the exporting service.

Parameters:

span - the Span to be added.

registerHandler

public void registerHandler(String name,
 SpanExporter.Handler handler)

Description copied from class: SpanExporter

Registers a new service handler that is used by the library to export SpanData for sampled spans (see TraceOptions.isSampled()).

Specified by:

registerHandler in class SpanExporter

Parameters:

name - the name of the service handler. Must be unique for each service.

handler - the service handler that is called for each ended sampled span.

unregisterHandler

public void unregisterHandler(String name)

Description copied from class: SpanExporter

Unregisters the service handler with the provided name.

Specified by:

unregisterHandler in class SpanExporter

Parameters:

name - the name of the service handler that will be unregistered.

flush

void flush()

shutdown

void shutdown()

getServiceExporterThread

Thread getServiceExporterThread()

getDroppedSpans

long getDroppedSpans()

getReferencedSpans

long getReferencedSpans()

getPushedSpans

long getPushedSpans()