io.micronaut.tracing.opentelemetry.instrument.util

Interface OpenTelemetryObserver<T>

Type Parameters:

T - The publisher's type

public interface OpenTelemetryObserver<T>

OpenTelemetry observer.

Since:

4.2.0

Author:

Nemanja Mikic

Field Summary

Fields

Modifier and Type	Field and Description
static OpenTelemetryObserver<?>	NO_OP No op observer.

Method Summary

Modifier and Type	Method and Description
default void	doOnError(java.lang.Throwable throwable, io.opentelemetry.context.Context openTelemetryContext) For subclasses to override and implement custom on-error behaviour.
default void	doOnFinish(io.opentelemetry.context.Context context) For subclasses to override and implement custom on-finish behaviour.
default void	doOnNext(T object, io.opentelemetry.context.Context context) For subclasses to override and implement custom behaviour when an item is emitted.
default void	doOnSubscribe(io.opentelemetry.context.Context context) For subclasses to override and implement custom on-subscribe behaviour.

Field Detail

NO_OP

static final OpenTelemetryObserver<?> NO_OP

No op observer.

Method Detail

doOnNext

default void doOnNext(@NonNull
                      T object,
                      @NonNull
                      io.opentelemetry.context.Context context)

For subclasses to override and implement custom behaviour when an item is emitted.

Parameters:

object - The object

context - The context

doOnSubscribe

default void doOnSubscribe(@NonNull
                           io.opentelemetry.context.Context context)

For subclasses to override and implement custom on-subscribe behaviour.

Parameters:

context - the context

doOnFinish

default void doOnFinish(@NonNull
                        io.opentelemetry.context.Context context)

For subclasses to override and implement custom on-finish behaviour. Fired prior to calling end on the span.

Parameters:

context - the context

doOnError

default void doOnError(@NonNull
                       java.lang.Throwable throwable,
                       @NonNull
                       io.opentelemetry.context.Context openTelemetryContext)

For subclasses to override and implement custom on-error behaviour.

Parameters:

throwable - the error

openTelemetryContext - the Context