Package io.opentelemetry.sdk.trace

Class MultiSpanProcessor

java.lang.Object

io.opentelemetry.sdk.trace.MultiSpanProcessor

All Implemented Interfaces:

ExtendedSpanProcessor, SpanProcessor, Closeable, AutoCloseable

final class MultiSpanProcessor
extends Object
implements ExtendedSpanProcessor

Implementation of the SpanProcessor that simply forwards all received events to a list of SpanProcessors.

Field Summary

Fields

Modifier and Type	Field	Description
private final AtomicBoolean	isShutdown
private final List<SpanProcessor>	spanProcessorsAll
private final List<SpanProcessor>	spanProcessorsEnd
private final List<ExtendedSpanProcessor>	spanProcessorsEnding
private final List<SpanProcessor>	spanProcessorsStart

Constructor Summary

Constructors

Modifier	Constructor	Description
private	MultiSpanProcessor(List<SpanProcessor> spanProcessors)

Method Summary

Modifier and Type	Method	Description
(package private) static SpanProcessor	create(List<SpanProcessor> spanProcessorList)	Creates a new MultiSpanProcessor.
CompletableResultCode	forceFlush()	Processes all span events that have not yet been processed.
boolean	isEndRequired()	Returns true if this SpanProcessor requires end events.
boolean	isOnEndingRequired()	Returns true if this SpanProcessor requires onEnding events.
boolean	isStartRequired()	Returns true if this SpanProcessor requires start events.
void	onEnd(ReadableSpan readableSpan)	Called when a Span is ended, if the Span.isRecording() returns true.
void	onEnding(ReadWriteSpan span)	Called when a Span is ended, but before SpanProcessor.onEnd(ReadableSpan) is invoked with an immutable variant of this span.
void	onStart(Context parentContext, ReadWriteSpan readWriteSpan)	Called when a Span is started, if the Span.isRecording() returns true.
CompletableResultCode	shutdown()	Processes all span events that have not yet been processed and closes used resources.
String	toString()

Methods inherited from class java.lang.Object

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

Methods inherited from interface io.opentelemetry.sdk.trace.SpanProcessor

close

Field Details

spanProcessorsStart

private final List<SpanProcessor> spanProcessorsStart

spanProcessorsEnding

private final List<ExtendedSpanProcessor> spanProcessorsEnding

spanProcessorsEnd

private final List<SpanProcessor> spanProcessorsEnd

spanProcessorsAll

private final List<SpanProcessor> spanProcessorsAll

isShutdown

private final AtomicBoolean isShutdown

Constructor Details

MultiSpanProcessor

private MultiSpanProcessor(List<SpanProcessor> spanProcessors)

Method Details

create

static SpanProcessor create(List<SpanProcessor> spanProcessorList)

Creates a new MultiSpanProcessor.

Parameters:

spanProcessorList - the List of SpanProcessors.

Returns:

a new MultiSpanProcessor.

Throws:

NullPointerException - if the spanProcessorList is null.

onStart

public void onStart(Context parentContext,
 ReadWriteSpan readWriteSpan)

Description copied from interface: SpanProcessor

Called when a Span is started, if the Span.isRecording() returns true.

This method is called synchronously on the execution thread, should not throw or block the execution thread.

Specified by:

onStart in interface SpanProcessor

Parameters:

parentContext - the parent Context of the span that just started.

readWriteSpan - the Span that just started.

isStartRequired

public boolean isStartRequired()

Description copied from interface: SpanProcessor

Returns true if this SpanProcessor requires start events.

Specified by:

isStartRequired in interface SpanProcessor

Returns:

true if this SpanProcessor requires start events.

onEnd

public void onEnd(ReadableSpan readableSpan)

Description copied from interface: SpanProcessor

Called when a Span is ended, if the Span.isRecording() returns true.

This method is called synchronously on the execution thread, should not throw or block the execution thread.

Specified by:

onEnd in interface SpanProcessor

Parameters:

readableSpan - the Span that just ended.

isEndRequired

public boolean isEndRequired()

Description copied from interface: SpanProcessor

Returns true if this SpanProcessor requires end events.

Specified by:

isEndRequired in interface SpanProcessor

Returns:

true if this SpanProcessor requires end events.

onEnding

public void onEnding(ReadWriteSpan span)

Description copied from interface: ExtendedSpanProcessor

Called when a Span is ended, but before SpanProcessor.onEnd(ReadableSpan) is invoked with an immutable variant of this span. This means that the span will still be mutable. Note that the span will only be modifiable synchronously from this callback, concurrent modifications from other threads will be prevented. Only called if Span.isRecording() returns true.

This method is called synchronously on the execution thread, should not throw or block the execution thread.

Specified by:

onEnding in interface ExtendedSpanProcessor

Parameters:

span - the Span that is just about to be ended.

isOnEndingRequired

public boolean isOnEndingRequired()

Description copied from interface: ExtendedSpanProcessor

Returns true if this SpanProcessor requires onEnding events.

Specified by:

isOnEndingRequired in interface ExtendedSpanProcessor

Returns:

true if this SpanProcessor requires onEnding events.

shutdown

public CompletableResultCode shutdown()

Description copied from interface: SpanProcessor

Processes all span events that have not yet been processed and closes used resources.

Specified by:

shutdown in interface SpanProcessor

Returns:

a CompletableResultCode which completes when shutdown is finished.

forceFlush

public CompletableResultCode forceFlush()

Description copied from interface: SpanProcessor

Processes all span events that have not yet been processed.

Specified by:

forceFlush in interface SpanProcessor

Returns:

a CompletableResultCode which completes when currently queued spans are finished processing.

toString

public String toString()

Overrides:

toString in class Object