io.micronaut.tracing.instrument.util

Class TracingCorePublisher<T>

java.lang.Object

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

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

Type Parameters:

T - the type of element signaled

All Implemented Interfaces:

io.micronaut.core.async.publisher.Publishers.MicronautPublisher<T>, org.reactivestreams.Publisher<T>, reactor.core.CorePublisher<T>

public class TracingCorePublisher<T>
extends TracingPublisher<T>
implements reactor.core.CorePublisher<T>

The tracing publisher that supports Reactor's context.

Author:

Denis Stepanov

Nested Class Summary

Nested classes/interfaces inherited from class io.micronaut.tracing.instrument.util.TracingPublisher

TracingPublisher.TracingSubscriber

Field Summary

Fields inherited from class io.micronaut.tracing.instrument.util.TracingPublisher

publisher

Constructor Summary

Constructors

Constructor and Description
TracingCorePublisher(reactor.core.CorePublisher<T> publisher, io.opentracing.Tracer tracer) Creates a new tracing publisher for the given arguments.
TracingCorePublisher(reactor.core.CorePublisher<T> publisher, io.opentracing.Tracer tracer, java.lang.String operationName) Creates a new tracing publisher for the given arguments.
TracingCorePublisher(reactor.core.CorePublisher<T> publisher, io.opentracing.Tracer tracer, java.lang.String operationName, TracingObserver tracingObserver) Creates a new tracing publisher for the given arguments.
TracingCorePublisher(reactor.core.CorePublisher<T> publisher, io.opentracing.Tracer tracer, io.opentracing.Tracer.SpanBuilder spanBuilder) Creates a new tracing publisher for the given arguments.
TracingCorePublisher(reactor.core.CorePublisher<T> publisher, io.opentracing.Tracer tracer, io.opentracing.Tracer.SpanBuilder spanBuilder, boolean isSingle) Creates a new tracing publisher for the given arguments.
TracingCorePublisher(reactor.core.CorePublisher<T> publisher, io.opentracing.Tracer tracer, io.opentracing.Tracer.SpanBuilder spanBuilder, boolean isSingle, TracingObserver tracingObserver) Creates a new tracing publisher for the given arguments.
TracingCorePublisher(reactor.core.CorePublisher<T> publisher, io.opentracing.Tracer tracer, io.opentracing.Tracer.SpanBuilder spanBuilder, TracingObserver tracingObserver) Creates a new tracing publisher for the given arguments.
TracingCorePublisher(reactor.core.CorePublisher<T> publisher, io.opentracing.Tracer tracer, TracingObserver tracingObserver) Creates a new tracing publisher for the given arguments.

Method Summary

Modifier and Type	Method and Description
protected void	doSubscribe(org.reactivestreams.Subscriber<? super T> actual, io.opentracing.ScopeManager scopeManager, io.opentracing.Span span, boolean finishOnClose) Do subscribe to the publisher.
void	subscribe(reactor.core.CoreSubscriber<? super T> subscriber)

Methods inherited from class io.micronaut.tracing.instrument.util.TracingPublisher

doOnError, doOnFinish, doOnNext, doOnSubscribe, isContinued, isFinishOnError, subscribe

Methods inherited from class java.lang.Object

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

Methods inherited from interface org.reactivestreams.Publisher

subscribe

Constructor Detail

TracingCorePublisher

public TracingCorePublisher(reactor.core.CorePublisher<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

TracingCorePublisher

public TracingCorePublisher(reactor.core.CorePublisher<T> publisher,
                            io.opentracing.Tracer tracer,
                            java.lang.String operationName,
                            TracingObserver tracingObserver)

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

tracingObserver - the tracing observer

TracingCorePublisher

public TracingCorePublisher(reactor.core.CorePublisher<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

TracingCorePublisher

public TracingCorePublisher(reactor.core.CorePublisher<T> publisher,
                            io.opentracing.Tracer tracer,
                            TracingObserver tracingObserver)

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

tracingObserver - the tracing observer

TracingCorePublisher

public TracingCorePublisher(reactor.core.CorePublisher<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

TracingCorePublisher

public TracingCorePublisher(reactor.core.CorePublisher<T> publisher,
                            io.opentracing.Tracer tracer,
                            io.opentracing.Tracer.SpanBuilder spanBuilder,
                            TracingObserver tracingObserver)

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

tracingObserver - the tracing observer

TracingCorePublisher

public TracingCorePublisher(reactor.core.CorePublisher<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 - true if the publisher emits a single item

TracingCorePublisher

public TracingCorePublisher(reactor.core.CorePublisher<T> publisher,
                            io.opentracing.Tracer tracer,
                            io.opentracing.Tracer.SpanBuilder spanBuilder,
                            boolean isSingle,
                            TracingObserver tracingObserver)

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 - true if the publisher emits a single item

tracingObserver - the tracing observer

Method Detail

subscribe

public void subscribe(reactor.core.CoreSubscriber<? super T> subscriber)

Specified by:

subscribe in interface reactor.core.CorePublisher<T>

doSubscribe

protected void doSubscribe(org.reactivestreams.Subscriber<? super T> actual,
                           io.opentracing.ScopeManager scopeManager,
                           io.opentracing.Span span,
                           boolean finishOnClose)

Description copied from class: TracingPublisher

Do subscribe to the publisher.

Overrides:

doSubscribe in class TracingPublisher<T>

Parameters:

actual - The actual subscriber

scopeManager - The scope manager

span - The span

finishOnClose - Should finish on close?