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

Constructor Summary

Constructors

Constructor and Description
TracingPublisherUtils()

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

Constructor Detail

TracingPublisherUtils

public TracingPublisherUtils()

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