-
Notifications
You must be signed in to change notification settings - Fork 845
Commit
This commit does not belong to any branch on this repository, and may belong to a fork outside of the repository.
code review comment + reactor-netty 0.9
- Loading branch information
Mateusz Rzeszutek
committed
Apr 29, 2021
1 parent
015a26d
commit 444efb4
Showing
4 changed files
with
305 additions
and
10 deletions.
There are no files selected for viewing
134 changes: 134 additions & 0 deletions
134
...java/io/opentelemetry/javaagent/instrumentation/reactornetty/v0_9/DecoratorFunctions.java
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
| Original file line number | Diff line number | Diff line change |
|---|---|---|
| @@ -0,0 +1,134 @@ | ||
| /* | ||
| * Copyright The OpenTelemetry Authors | ||
| * SPDX-License-Identifier: Apache-2.0 | ||
| */ | ||
|
|
||
| package io.opentelemetry.javaagent.instrumentation.reactornetty.v0_9; | ||
|
|
||
| import io.netty.channel.Channel; | ||
| import io.opentelemetry.context.Context; | ||
| import io.opentelemetry.context.Scope; | ||
| import io.opentelemetry.instrumentation.netty.v4_1.AttributeKeys; | ||
| import java.util.function.BiConsumer; | ||
| import org.checkerframework.checker.nullness.qual.Nullable; | ||
| import reactor.netty.Connection; | ||
| import reactor.netty.http.client.HttpClientRequest; | ||
| import reactor.netty.http.client.HttpClientResponse; | ||
|
|
||
| public final class DecoratorFunctions { | ||
|
|
||
| // ignore our own callbacks - or already decorated functions | ||
| public static boolean shouldDecorate(Class<?> callbackClass) { | ||
| return !callbackClass.getName().startsWith("io.opentelemetry.javaagent"); | ||
| } | ||
|
|
||
| private abstract static class OnMessageDecorator<M> implements BiConsumer<M, Connection> { | ||
| private final BiConsumer<? super M, ? super Connection> delegate; | ||
|
|
||
| public OnMessageDecorator(BiConsumer<? super M, ? super Connection> delegate) { | ||
| this.delegate = delegate; | ||
| } | ||
|
|
||
| @Override | ||
| public final void accept(M message, Connection connection) { | ||
| Context context = getChannelContext(currentContext(message), connection.channel()); | ||
| if (context == null) { | ||
| delegate.accept(message, connection); | ||
| } else { | ||
| try (Scope ignored = context.makeCurrent()) { | ||
| delegate.accept(message, connection); | ||
| } | ||
| } | ||
| } | ||
|
|
||
| abstract reactor.util.context.Context currentContext(M message); | ||
| } | ||
|
|
||
| public static final class OnRequestDecorator extends OnMessageDecorator<HttpClientRequest> { | ||
| public OnRequestDecorator(BiConsumer<? super HttpClientRequest, ? super Connection> delegate) { | ||
| super(delegate); | ||
| } | ||
|
|
||
| @Override | ||
| reactor.util.context.Context currentContext(HttpClientRequest message) { | ||
| return message.currentContext(); | ||
| } | ||
| } | ||
|
|
||
| public static final class OnResponseDecorator extends OnMessageDecorator<HttpClientResponse> { | ||
| public OnResponseDecorator( | ||
| BiConsumer<? super HttpClientResponse, ? super Connection> delegate) { | ||
| super(delegate); | ||
| } | ||
|
|
||
| @Override | ||
| reactor.util.context.Context currentContext(HttpClientResponse message) { | ||
| return message.currentContext(); | ||
| } | ||
| } | ||
|
|
||
| private abstract static class OnMessageErrorDecorator<M> implements BiConsumer<M, Throwable> { | ||
| private final BiConsumer<? super M, ? super Throwable> delegate; | ||
|
|
||
| public OnMessageErrorDecorator(BiConsumer<? super M, ? super Throwable> delegate) { | ||
| this.delegate = delegate; | ||
| } | ||
|
|
||
| @Override | ||
| public final void accept(M message, Throwable throwable) { | ||
| Context context = getChannelContext(currentContext(message), null); | ||
| if (context == null) { | ||
| delegate.accept(message, throwable); | ||
| } else { | ||
| try (Scope ignored = context.makeCurrent()) { | ||
| delegate.accept(message, throwable); | ||
| } | ||
| } | ||
| } | ||
|
|
||
| abstract reactor.util.context.Context currentContext(M message); | ||
| } | ||
|
|
||
| public static final class OnRequestErrorDecorator | ||
| extends OnMessageErrorDecorator<HttpClientRequest> { | ||
| public OnRequestErrorDecorator( | ||
| BiConsumer<? super HttpClientRequest, ? super Throwable> delegate) { | ||
| super(delegate); | ||
| } | ||
|
|
||
| @Override | ||
| reactor.util.context.Context currentContext(HttpClientRequest message) { | ||
| return message.currentContext(); | ||
| } | ||
| } | ||
|
|
||
| public static final class OnResponseErrorDecorator | ||
| extends OnMessageErrorDecorator<HttpClientResponse> { | ||
| public OnResponseErrorDecorator( | ||
| BiConsumer<? super HttpClientResponse, ? super Throwable> delegate) { | ||
| super(delegate); | ||
| } | ||
|
|
||
| @Override | ||
| reactor.util.context.Context currentContext(HttpClientResponse message) { | ||
| return message.currentContext(); | ||
| } | ||
| } | ||
|
|
||
| @Nullable | ||
| private static Context getChannelContext( | ||
| reactor.util.context.Context reactorContext, @Nullable Channel channel) { | ||
| // try to get the client span context from the channel if it's available | ||
| if (channel != null) { | ||
| Context context = channel.attr(AttributeKeys.CLIENT_CONTEXT).get(); | ||
| if (context != null) { | ||
| return context; | ||
| } | ||
| } | ||
| // otherwise use the parent span context | ||
| return reactorContext.getOrDefault( | ||
| ReactorNettyInstrumentationModule.MapConnect.CONTEXT_ATTRIBUTE, null); | ||
| } | ||
|
|
||
| private DecoratorFunctions() {} | ||
| } |
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters