io.micronaut.tracing.opentelemetry.instrument.util

Class OpenTelemetryPublisherUtils

java.lang.Object

io.micronaut.tracing.opentelemetry.instrument.util.OpenTelemetryPublisherUtils

public final class OpenTelemetryPublisherUtils
extends java.lang.Object

The tracing observer.

Since:

4.2.0

Author:

Nemanja Mikic

Method Summary

Modifier and Type	Method and Description
static <T,R> OpenTelemetryPublisher<T,R>	createOpenTelemetryPublisher(org.reactivestreams.Publisher<T> publisher, io.opentelemetry.instrumentation.api.instrumenter.Instrumenter<R,java.lang.Object> instrumenter, io.opentelemetry.context.Context context, R request) Creates a new tracing publisher for the given arguments.
static <T,R> OpenTelemetryPublisher<T,R>	createOpenTelemetryPublisher(org.reactivestreams.Publisher<T> publisher, io.opentelemetry.instrumentation.api.instrumenter.Instrumenter<R,java.lang.Object> instrumenter, io.opentelemetry.context.Context context, R request, OpenTelemetryObserver<T> observer) Creates a new tracing publisher for the given arguments.
static void	logError(io.opentelemetry.context.Context context, java.lang.Throwable e) Logs an error to the span.

Methods inherited from class java.lang.Object

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

Method Detail

createOpenTelemetryPublisher

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

Creates a new tracing publisher for the given arguments.

Type Parameters:

T - The publisher's type

R - the type of request element

Parameters:

publisher - the target publisher

instrumenter - the instrumenter

request - the request object

context - the Open Telemetry context

observer - the tracing observer

Returns:

new instance

createOpenTelemetryPublisher

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

Creates a new tracing publisher for the given arguments.

Type Parameters:

T - The publisher's type

R - the type of request element

Parameters:

publisher - the target publisher

instrumenter - the instrumenter

context - the Open Telemetry context

request - the request object

Returns:

new instance

logError

public static void logError(io.opentelemetry.context.Context context,
                            java.lang.Throwable e)

Logs an error to the span.

Parameters:

context - the span

e - the error