io.micronaut.tracing.instrument.util

Class TracingPublisher<T>

java.lang.Object

io.micronaut.tracing.instrument.util.TracingPublisher<T>

Type Parameters:

T - the type of element signaled

All Implemented Interfaces:

Publishers.MicronautPublisher<T>, org.reactivestreams.Publisher<T>

public class TracingPublisher<T>
extends java.lang.Object
implements Publishers.MicronautPublisher<T>

A reactive streams publisher that traces.

Since:

1.0

Author:

graemerocher

Constructor Summary

Constructors

Constructor and Description
TracingPublisher(org.reactivestreams.Publisher<T> publisher, io.opentracing.Tracer tracer) Creates a new tracing publisher for the given arguments.
TracingPublisher(org.reactivestreams.Publisher<T> publisher, io.opentracing.Tracer tracer, java.lang.String operationName) Creates a new tracing publisher for the given arguments.
TracingPublisher(org.reactivestreams.Publisher<T> publisher, io.opentracing.Tracer tracer, io.opentracing.Tracer.SpanBuilder spanBuilder) Creates a new tracing publisher for the given arguments.
TracingPublisher(org.reactivestreams.Publisher<T> publisher, io.opentracing.Tracer tracer, io.opentracing.Tracer.SpanBuilder spanBuilder, boolean isSingle) Creates a new tracing publisher for the given arguments.

Method Summary

Modifier and Type	Method and Description
protected void	doOnError(java.lang.Throwable throwable, io.opentracing.Span span) Designed for subclasses to override and implement custom on error behaviour.
protected void	doOnFinish(io.opentracing.Span span) Designed for subclasses to override and implement custom on finish behaviour.
protected void	doOnNext(T object, io.opentracing.Span span) Designed for subclasses to override and implement custom behaviour when an item is emitted.
protected void	doOnSubscribe(io.opentracing.Span span) Designed for subclasses to override and implement custom on subscribe behaviour.
protected boolean	isContinued() Designed for subclasses to override if the current active span is to be continued by this publisher.
protected boolean	isFinishOnError() Designed for subclasses to override if the span needs to be finished upon error.
void	subscribe(org.reactivestreams.Subscriber<? super T> actual)

Methods inherited from class java.lang.Object

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

Constructor Detail

TracingPublisher

public TracingPublisher(org.reactivestreams.Publisher<T> publisher,
                        io.opentracing.Tracer tracer,
                        java.lang.String operationName)

Creates a new tracing publisher for the given arguments.

Parameters:

publisher - The target publisher

tracer - The tracer

operationName - The operation name that should be started

TracingPublisher

public TracingPublisher(org.reactivestreams.Publisher<T> publisher,
                        io.opentracing.Tracer tracer)

Creates a new tracing publisher for the given arguments. This constructor will just add tracing of the existing span if it is present.

Parameters:

publisher - The target publisher

tracer - The tracer

TracingPublisher

public TracingPublisher(org.reactivestreams.Publisher<T> publisher,
                        io.opentracing.Tracer tracer,
                        io.opentracing.Tracer.SpanBuilder spanBuilder)

Creates a new tracing publisher for the given arguments.

Parameters:

publisher - The target publisher

tracer - The tracer

spanBuilder - The span builder that represents the span that will be created when the publisher is subscribed to

TracingPublisher

public TracingPublisher(org.reactivestreams.Publisher<T> publisher,
                        io.opentracing.Tracer tracer,
                        io.opentracing.Tracer.SpanBuilder spanBuilder,
                        boolean isSingle)

Creates a new tracing publisher for the given arguments.

Parameters:

publisher - The target publisher

tracer - The tracer

spanBuilder - The span builder that represents the span that will be created when the publisher is subscribed to

isSingle - Does the publisher emit a single item

Method Detail

subscribe

public void subscribe(org.reactivestreams.Subscriber<? super T> actual)

Specified by:

subscribe in interface org.reactivestreams.Publisher<T>

isContinued

protected boolean isContinued()

Designed for subclasses to override if the current active span is to be continued by this publisher. False by default. This only has effects if no spanBuilder was defined.

Returns:

true, if the current span should be continued by this publisher

Since:

2.0.3

isFinishOnError

protected boolean isFinishOnError()

Designed for subclasses to override if the span needs to be finished upon error. True by default.

Returns:

true, if the active span needs to be finished on error

Since:

2.0.3

doOnNext

protected void doOnNext(@NonNull
                        T object,
                        @NonNull
                        io.opentracing.Span span)

Designed for subclasses to override and implement custom behaviour when an item is emitted.

Parameters:

object - The object

span - The span

doOnSubscribe

protected void doOnSubscribe(@NonNull
                             io.opentracing.Span span)

Designed for subclasses to override and implement custom on subscribe behaviour.

Parameters:

span - The span

doOnFinish

protected void doOnFinish(@NonNull
                          io.opentracing.Span span)

Designed for subclasses to override and implement custom on finish behaviour. Fired prior to calling Span.finish().

Parameters:

span - The span

doOnError

protected void doOnError(@NonNull
                         java.lang.Throwable throwable,
                         @NonNull
                         io.opentracing.Span span)

Designed for subclasses to override and implement custom on error behaviour.

Parameters:

throwable - The error

span - The span