io.micronaut.tracing.opentelemetry.instrument.util

Class OpenTelemetryCorePublisher<T,R>

java.lang.Object

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

io.micronaut.tracing.opentelemetry.instrument.util.OpenTelemetryCorePublisher<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>, reactor.core.CorePublisher<T>

public class OpenTelemetryCorePublisher<T,R>
extends OpenTelemetryPublisher<T,R>
implements reactor.core.CorePublisher<T>

A reactor publisher that traces.

Since:

4.2.0

Author:

Nemanja Mikic

Nested Class Summary

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

OpenTelemetryPublisher.TracingSubscriber

Field Summary

Fields inherited from class io.micronaut.tracing.opentelemetry.instrument.util.OpenTelemetryPublisher

publisher

Constructor Summary

Constructors

Constructor and Description
OpenTelemetryCorePublisher(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(reactor.core.CoreSubscriber<? super T> subscriber)

Methods inherited from class io.micronaut.tracing.opentelemetry.instrument.util.OpenTelemetryPublisher

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

OpenTelemetryCorePublisher

public OpenTelemetryCorePublisher(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)

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(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.opentelemetry.context.Context context)

Description copied from class: OpenTelemetryPublisher

Do subscribe to the publisher.

Overrides:

doSubscribe in class OpenTelemetryPublisher<T,R>

Parameters:

actual - The actual subscriber

context - The context