io.micronaut.tracing.instrument.util

Class TracingPublisherUtils

java.lang.Object

io.micronaut.tracing.instrument.util.TracingPublisherUtils

public final class TracingPublisherUtils
extends java.lang.Object

Tracing publisher utils.

Author:

Denis Stepanov

Method Summary

Modifier and Type	Method and Description
static <T> TracingPublisher<T>	createTracingPublisher(org.reactivestreams.Publisher<T> publisher, io.opentracing.Tracer tracer, io.opentracing.Tracer.SpanBuilder spanBuilder, boolean isSingle, TracingObserver<T> tracingObserver) Creates a new tracing publisher for the given arguments.
static <T> TracingPublisher<T>	createTracingPublisher(org.reactivestreams.Publisher<T> publisher, io.opentracing.Tracer tracer, io.opentracing.Tracer.SpanBuilder spanBuilder, TracingObserver<T> tracingObserver) Creates a new tracing publisher for the given arguments.
static <T> TracingPublisher<T>	createTracingPublisher(org.reactivestreams.Publisher<T> publisher, io.opentracing.Tracer tracer, TracingObserver<T> tracingObserver) Creates a new tracing publisher for the given arguments.

Methods inherited from class java.lang.Object

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

Method Detail

createTracingPublisher

public static <T> TracingPublisher<T> createTracingPublisher(org.reactivestreams.Publisher<T> publisher,
                                                             io.opentracing.Tracer tracer,
                                                             @NonNull
                                                             TracingObserver<T> tracingObserver)

Creates a new tracing publisher for the given arguments.

Type Parameters:

T - the publisher's type

Parameters:

publisher - the target publisher

tracer - the tracer

tracingObserver - the tracing observer

Returns:

new instance

createTracingPublisher

public static <T> TracingPublisher<T> createTracingPublisher(org.reactivestreams.Publisher<T> publisher,
                                                             io.opentracing.Tracer tracer,
                                                             io.opentracing.Tracer.SpanBuilder spanBuilder,
                                                             @NonNull
                                                             TracingObserver<T> tracingObserver)

Creates a new tracing publisher for the given arguments.

Type Parameters:

T - the publisher's type

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

tracingObserver - the tracing observer

Returns:

new instance

createTracingPublisher

public static <T> TracingPublisher<T> createTracingPublisher(org.reactivestreams.Publisher<T> publisher,
                                                             io.opentracing.Tracer tracer,
                                                             io.opentracing.Tracer.SpanBuilder spanBuilder,
                                                             boolean isSingle,
                                                             @NonNull
                                                             TracingObserver<T> tracingObserver)

Creates a new tracing publisher for the given arguments.

Type Parameters:

T - the publisher's type

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

Returns:

new instance