io.micronaut.tracing.opentelemetry.instrument.util

Class OpenTelemetryPublisher<T,R>

java.lang.Object

io.micronaut.tracing.opentelemetry.instrument.util.OpenTelemetryPublisher<T,R>

Type Parameters:

T - the type of element signaled

R - the type of request element

All Implemented Interfaces:

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

Direct Known Subclasses:

OpenTelemetryCorePublisher

public class OpenTelemetryPublisher<T,R>
extends java.lang.Object
implements io.micronaut.core.async.publisher.Publishers.MicronautPublisher<T>

A reactive streams publisher that traces.

Since:

4.2.0

Author:

Nemanja Mikic

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
protected class	OpenTelemetryPublisher.TracingSubscriber The tracing subscriber.

Field Summary

Fields

Modifier and Type	Field and Description
protected org.reactivestreams.Publisher<T>	publisher

Constructor Summary

Constructors

Constructor and Description
OpenTelemetryPublisher(org.reactivestreams.Publisher<T> publisher, io.opentelemetry.instrumentation.api.instrumenter.Instrumenter<R,java.lang.Object> instrumenter, io.opentelemetry.context.Context parentContext, R request, OpenTelemetryObserver<T> observer)

Method Summary

Modifier and Type	Method and Description
protected void	doSubscribe(org.reactivestreams.Subscriber<? super T> actual, io.opentelemetry.context.Context context) Do subscribe to the publisher.
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

Field Detail

publisher

protected final org.reactivestreams.Publisher<T> publisher

Constructor Detail

OpenTelemetryPublisher

public OpenTelemetryPublisher(org.reactivestreams.Publisher<T> publisher,
                              io.opentelemetry.instrumentation.api.instrumenter.Instrumenter<R,java.lang.Object> instrumenter,
                              io.opentelemetry.context.Context parentContext,
                              @Nullable
                              R request,
                              OpenTelemetryObserver<T> observer)

Parameters:

publisher - the target publisher

instrumenter - the instrumenter

parentContext - the context from a parent

request - the request object

observer - the tracing observer

Method Detail

subscribe

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

Specified by:

subscribe in interface org.reactivestreams.Publisher<T>

doSubscribe

@Internal
protected void doSubscribe(org.reactivestreams.Subscriber<? super T> actual,
                                     io.opentelemetry.context.Context context)

Do subscribe to the publisher.

Parameters:

actual - The actual subscriber

context - The context