switch annotation `org.checkerframework.checker.nullness.qual.Nullable` to `javax.annotation.Nullable` (#4418)

This commit is contained in:
Martin 2021-10-19 15:59:18 +08:00 committed by GitHub
parent 25910d99d3
commit 62c90512cd
No known key found for this signature in database
GPG Key ID: 4AEE18F83AFDEB23
15 changed files with 69 additions and 46 deletions

View File

@ -10,7 +10,7 @@ import akka.http.scaladsl.model.HttpResponse;
import io.opentelemetry.instrumentation.api.instrumenter.http.HttpClientAttributesExtractor; import io.opentelemetry.instrumentation.api.instrumenter.http.HttpClientAttributesExtractor;
import io.opentelemetry.javaagent.instrumentation.akkahttp.AkkaHttpUtil; import io.opentelemetry.javaagent.instrumentation.akkahttp.AkkaHttpUtil;
import java.util.List; import java.util.List;
import org.checkerframework.checker.nullness.qual.Nullable; import javax.annotation.Nullable;
class AkkaHttpClientAttributesExtractor class AkkaHttpClientAttributesExtractor
extends HttpClientAttributesExtractor<HttpRequest, HttpResponse> { extends HttpClientAttributesExtractor<HttpRequest, HttpResponse> {
@ -35,13 +35,15 @@ class AkkaHttpClientAttributesExtractor
} }
@Override @Override
protected @Nullable Long requestContentLength( @Nullable
protected Long requestContentLength(
HttpRequest httpRequest, @Nullable HttpResponse httpResponse) { HttpRequest httpRequest, @Nullable HttpResponse httpResponse) {
return null; return null;
} }
@Override @Override
protected @Nullable Long requestContentLengthUncompressed( @Nullable
protected Long requestContentLengthUncompressed(
HttpRequest httpRequest, @Nullable HttpResponse httpResponse) { HttpRequest httpRequest, @Nullable HttpResponse httpResponse) {
return null; return null;
} }
@ -52,13 +54,14 @@ class AkkaHttpClientAttributesExtractor
} }
@Override @Override
protected @Nullable Long responseContentLength( @Nullable
HttpRequest httpRequest, HttpResponse httpResponse) { protected Long responseContentLength(HttpRequest httpRequest, HttpResponse httpResponse) {
return null; return null;
} }
@Override @Override
protected @Nullable Long responseContentLengthUncompressed( @Nullable
protected Long responseContentLengthUncompressed(
HttpRequest httpRequest, HttpResponse httpResponse) { HttpRequest httpRequest, HttpResponse httpResponse) {
return null; return null;
} }

View File

@ -9,7 +9,7 @@ import akka.http.scaladsl.model.HttpRequest;
import akka.http.scaladsl.model.HttpResponse; import akka.http.scaladsl.model.HttpResponse;
import io.opentelemetry.instrumentation.api.instrumenter.net.NetClientAttributesExtractor; import io.opentelemetry.instrumentation.api.instrumenter.net.NetClientAttributesExtractor;
import io.opentelemetry.semconv.trace.attributes.SemanticAttributes; import io.opentelemetry.semconv.trace.attributes.SemanticAttributes;
import org.checkerframework.checker.nullness.qual.Nullable; import javax.annotation.Nullable;
class AkkaHttpNetAttributesExtractor class AkkaHttpNetAttributesExtractor
extends NetClientAttributesExtractor<HttpRequest, HttpResponse> { extends NetClientAttributesExtractor<HttpRequest, HttpResponse> {
@ -29,7 +29,8 @@ class AkkaHttpNetAttributesExtractor
} }
@Override @Override
public @Nullable String peerIp(HttpRequest httpRequest, @Nullable HttpResponse httpResponse) { @Nullable
public String peerIp(HttpRequest httpRequest, @Nullable HttpResponse httpResponse) {
return null; return null;
} }
} }

View File

@ -10,7 +10,7 @@ import akka.http.scaladsl.model.HttpResponse;
import io.opentelemetry.instrumentation.api.instrumenter.http.HttpServerAttributesExtractor; import io.opentelemetry.instrumentation.api.instrumenter.http.HttpServerAttributesExtractor;
import io.opentelemetry.javaagent.instrumentation.akkahttp.AkkaHttpUtil; import io.opentelemetry.javaagent.instrumentation.akkahttp.AkkaHttpUtil;
import java.util.List; import java.util.List;
import org.checkerframework.checker.nullness.qual.Nullable; import javax.annotation.Nullable;
import scala.Option; import scala.Option;
class AkkaHttpServerAttributesExtractor class AkkaHttpServerAttributesExtractor
@ -27,13 +27,14 @@ class AkkaHttpServerAttributesExtractor
} }
@Override @Override
protected @Nullable Long requestContentLength( @Nullable
HttpRequest request, @Nullable HttpResponse httpResponse) { protected Long requestContentLength(HttpRequest request, @Nullable HttpResponse httpResponse) {
return null; return null;
} }
@Override @Override
protected @Nullable Long requestContentLengthUncompressed( @Nullable
protected Long requestContentLengthUncompressed(
HttpRequest request, @Nullable HttpResponse httpResponse) { HttpRequest request, @Nullable HttpResponse httpResponse) {
return null; return null;
} }
@ -44,13 +45,14 @@ class AkkaHttpServerAttributesExtractor
} }
@Override @Override
protected @Nullable Long responseContentLength(HttpRequest request, HttpResponse httpResponse) { @Nullable
protected Long responseContentLength(HttpRequest request, HttpResponse httpResponse) {
return null; return null;
} }
@Override @Override
protected @Nullable Long responseContentLengthUncompressed( @Nullable
HttpRequest request, HttpResponse httpResponse) { protected Long responseContentLengthUncompressed(HttpRequest request, HttpResponse httpResponse) {
return null; return null;
} }
@ -76,7 +78,8 @@ class AkkaHttpServerAttributesExtractor
} }
@Override @Override
protected @Nullable String route(HttpRequest request) { @Nullable
protected String route(HttpRequest request) {
return null; return null;
} }
@ -86,7 +89,8 @@ class AkkaHttpServerAttributesExtractor
} }
@Override @Override
protected @Nullable String serverName(HttpRequest request, @Nullable HttpResponse httpResponse) { @Nullable
protected String serverName(HttpRequest request, @Nullable HttpResponse httpResponse) {
return null; return null;
} }
} }

View File

@ -23,7 +23,7 @@ import java.io.UnsupportedEncodingException;
import java.net.URLEncoder; import java.net.URLEncoder;
import java.nio.charset.StandardCharsets; import java.nio.charset.StandardCharsets;
import java.util.Map; import java.util.Map;
import org.checkerframework.checker.nullness.qual.Nullable; import javax.annotation.Nullable;
final class ApiGatewayProxyAttributesExtractor final class ApiGatewayProxyAttributesExtractor
implements AttributesExtractor<AwsLambdaRequest, Object> { implements AttributesExtractor<AwsLambdaRequest, Object> {

View File

@ -16,7 +16,7 @@ import io.opentelemetry.instrumentation.awslambda.v1_0.AwsLambdaRequest;
import java.lang.invoke.MethodHandle; import java.lang.invoke.MethodHandle;
import java.lang.invoke.MethodHandles; import java.lang.invoke.MethodHandles;
import java.lang.invoke.MethodType; import java.lang.invoke.MethodType;
import org.checkerframework.checker.nullness.qual.Nullable; import javax.annotation.Nullable;
class AwsLambdaFunctionAttributesExtractor class AwsLambdaFunctionAttributesExtractor
implements AttributesExtractor<AwsLambdaRequest, Object> { implements AttributesExtractor<AwsLambdaRequest, Object> {

View File

@ -12,7 +12,7 @@ import io.opentelemetry.instrumentation.api.instrumenter.Instrumenter;
import io.opentelemetry.instrumentation.api.internal.ContextPropagationDebug; import io.opentelemetry.instrumentation.api.internal.ContextPropagationDebug;
import io.opentelemetry.instrumentation.awslambda.v1_0.AwsLambdaRequest; import io.opentelemetry.instrumentation.awslambda.v1_0.AwsLambdaRequest;
import java.util.Map; import java.util.Map;
import org.checkerframework.checker.nullness.qual.Nullable; import javax.annotation.Nullable;
public class AwsLambdaFunctionInstrumenter { public class AwsLambdaFunctionInstrumenter {

View File

@ -9,7 +9,7 @@ import com.amazonaws.services.lambda.runtime.events.SQSEvent;
import io.opentelemetry.api.common.AttributesBuilder; import io.opentelemetry.api.common.AttributesBuilder;
import io.opentelemetry.instrumentation.api.instrumenter.AttributesExtractor; import io.opentelemetry.instrumentation.api.instrumenter.AttributesExtractor;
import io.opentelemetry.semconv.trace.attributes.SemanticAttributes; import io.opentelemetry.semconv.trace.attributes.SemanticAttributes;
import org.checkerframework.checker.nullness.qual.Nullable; import javax.annotation.Nullable;
class SqsEventAttributesExtractor implements AttributesExtractor<SQSEvent, Void> { class SqsEventAttributesExtractor implements AttributesExtractor<SQSEvent, Void> {
@Override @Override

View File

@ -9,7 +9,7 @@ import com.amazonaws.services.lambda.runtime.events.SQSEvent.SQSMessage;
import io.opentelemetry.api.common.AttributesBuilder; import io.opentelemetry.api.common.AttributesBuilder;
import io.opentelemetry.instrumentation.api.instrumenter.AttributesExtractor; import io.opentelemetry.instrumentation.api.instrumenter.AttributesExtractor;
import io.opentelemetry.semconv.trace.attributes.SemanticAttributes; import io.opentelemetry.semconv.trace.attributes.SemanticAttributes;
import org.checkerframework.checker.nullness.qual.Nullable; import javax.annotation.Nullable;
class SqsMessageAttributesExtractor implements AttributesExtractor<SQSMessage, Void> { class SqsMessageAttributesExtractor implements AttributesExtractor<SQSMessage, Void> {
@Override @Override

View File

@ -13,8 +13,8 @@ import io.opentelemetry.api.common.AttributesBuilder;
import io.opentelemetry.instrumentation.api.instrumenter.AttributesExtractor; import io.opentelemetry.instrumentation.api.instrumenter.AttributesExtractor;
import java.util.HashSet; import java.util.HashSet;
import java.util.Set; import java.util.Set;
import javax.annotation.Nullable;
import org.bson.BsonValue; import org.bson.BsonValue;
import org.checkerframework.checker.nullness.qual.Nullable;
class MongoAttributesExtractor implements AttributesExtractor<CommandStartedEvent, Void> { class MongoAttributesExtractor implements AttributesExtractor<CommandStartedEvent, Void> {
@Override @Override

View File

@ -8,12 +8,13 @@ package io.opentelemetry.instrumentation.mongo.v3_1;
import com.mongodb.event.CommandStartedEvent; import com.mongodb.event.CommandStartedEvent;
import io.opentelemetry.instrumentation.api.instrumenter.net.InetSocketAddressNetClientAttributesExtractor; import io.opentelemetry.instrumentation.api.instrumenter.net.InetSocketAddressNetClientAttributesExtractor;
import java.net.InetSocketAddress; import java.net.InetSocketAddress;
import org.checkerframework.checker.nullness.qual.Nullable; import javax.annotation.Nullable;
class MongoNetAttributesExtractor class MongoNetAttributesExtractor
extends InetSocketAddressNetClientAttributesExtractor<CommandStartedEvent, Void> { extends InetSocketAddressNetClientAttributesExtractor<CommandStartedEvent, Void> {
@Override @Override
public @Nullable InetSocketAddress getAddress(CommandStartedEvent event, @Nullable Void unused) { @Nullable
public InetSocketAddress getAddress(CommandStartedEvent event, @Nullable Void unused) {
if (event.getConnectionDescription() != null if (event.getConnectionDescription() != null
&& event.getConnectionDescription().getServerAddress() != null) { && event.getConnectionDescription().getServerAddress() != null) {
return event.getConnectionDescription().getServerAddress().getSocketAddress(); return event.getConnectionDescription().getServerAddress().getSocketAddress();
@ -23,8 +24,8 @@ class MongoNetAttributesExtractor
} }
@Override @Override
public @Nullable String transport( @Nullable
CommandStartedEvent commandStartedEvent, @Nullable Void unused) { public String transport(CommandStartedEvent commandStartedEvent, @Nullable Void unused) {
return null; return null;
} }
} }

View File

@ -8,7 +8,7 @@ package io.opentelemetry.javaagent.instrumentation.netty.v3_8.client;
import com.google.auto.value.AutoValue; import com.google.auto.value.AutoValue;
import io.opentelemetry.context.Context; import io.opentelemetry.context.Context;
import io.opentelemetry.javaagent.instrumentation.netty.v3_8.HttpRequestAndChannel; import io.opentelemetry.javaagent.instrumentation.netty.v3_8.HttpRequestAndChannel;
import org.checkerframework.checker.nullness.qual.Nullable; import javax.annotation.Nullable;
@AutoValue @AutoValue
abstract class NettyClientRequestAndContexts { abstract class NettyClientRequestAndContexts {

View File

@ -10,14 +10,15 @@ import io.opentelemetry.javaagent.instrumentation.netty.v3_8.HttpRequestAndChann
import java.net.URI; import java.net.URI;
import java.net.URISyntaxException; import java.net.URISyntaxException;
import java.util.List; import java.util.List;
import org.checkerframework.checker.nullness.qual.Nullable; import javax.annotation.Nullable;
import org.jboss.netty.handler.codec.http.HttpResponse; import org.jboss.netty.handler.codec.http.HttpResponse;
final class NettyHttpClientAttributesExtractor final class NettyHttpClientAttributesExtractor
extends HttpClientAttributesExtractor<HttpRequestAndChannel, HttpResponse> { extends HttpClientAttributesExtractor<HttpRequestAndChannel, HttpResponse> {
@Override @Override
protected @Nullable String url(HttpRequestAndChannel requestAndChannel) { @Nullable
protected String url(HttpRequestAndChannel requestAndChannel) {
try { try {
String hostHeader = getHost(requestAndChannel); String hostHeader = getHost(requestAndChannel);
String target = requestAndChannel.request().getUri(); String target = requestAndChannel.request().getUri();
@ -58,13 +59,15 @@ final class NettyHttpClientAttributesExtractor
} }
@Override @Override
protected @Nullable Long requestContentLength( @Nullable
protected Long requestContentLength(
HttpRequestAndChannel requestAndChannel, @Nullable HttpResponse response) { HttpRequestAndChannel requestAndChannel, @Nullable HttpResponse response) {
return null; return null;
} }
@Override @Override
protected @Nullable Long requestContentLengthUncompressed( @Nullable
protected Long requestContentLengthUncompressed(
HttpRequestAndChannel requestAndChannel, @Nullable HttpResponse response) { HttpRequestAndChannel requestAndChannel, @Nullable HttpResponse response) {
return null; return null;
} }
@ -75,13 +78,15 @@ final class NettyHttpClientAttributesExtractor
} }
@Override @Override
protected @Nullable Long responseContentLength( @Nullable
protected Long responseContentLength(
HttpRequestAndChannel requestAndChannel, HttpResponse response) { HttpRequestAndChannel requestAndChannel, HttpResponse response) {
return null; return null;
} }
@Override @Override
protected @Nullable Long responseContentLengthUncompressed( @Nullable
protected Long responseContentLengthUncompressed(
HttpRequestAndChannel requestAndChannel, HttpResponse response) { HttpRequestAndChannel requestAndChannel, HttpResponse response) {
return null; return null;
} }

View File

@ -9,14 +9,15 @@ import io.opentelemetry.instrumentation.api.instrumenter.net.InetSocketAddressNe
import io.opentelemetry.javaagent.instrumentation.netty.v3_8.HttpRequestAndChannel; import io.opentelemetry.javaagent.instrumentation.netty.v3_8.HttpRequestAndChannel;
import java.net.InetSocketAddress; import java.net.InetSocketAddress;
import java.net.SocketAddress; import java.net.SocketAddress;
import org.checkerframework.checker.nullness.qual.Nullable; import javax.annotation.Nullable;
import org.jboss.netty.handler.codec.http.HttpResponse; import org.jboss.netty.handler.codec.http.HttpResponse;
final class NettyNetClientAttributesExtractor final class NettyNetClientAttributesExtractor
extends InetSocketAddressNetClientAttributesExtractor<HttpRequestAndChannel, HttpResponse> { extends InetSocketAddressNetClientAttributesExtractor<HttpRequestAndChannel, HttpResponse> {
@Override @Override
public @Nullable InetSocketAddress getAddress( @Nullable
public InetSocketAddress getAddress(
HttpRequestAndChannel requestAndChannel, @Nullable HttpResponse response) { HttpRequestAndChannel requestAndChannel, @Nullable HttpResponse response) {
SocketAddress address = requestAndChannel.channel().getRemoteAddress(); SocketAddress address = requestAndChannel.channel().getRemoteAddress();
if (address instanceof InetSocketAddress) { if (address instanceof InetSocketAddress) {
@ -26,7 +27,8 @@ final class NettyNetClientAttributesExtractor
} }
@Override @Override
public @Nullable String transport( @Nullable
public String transport(
HttpRequestAndChannel requestAndChannel, @Nullable HttpResponse response) { HttpRequestAndChannel requestAndChannel, @Nullable HttpResponse response) {
return null; return null;
} }

View File

@ -12,7 +12,7 @@ import io.opentelemetry.javaagent.instrumentation.netty.common.HttpRequestAndCha
import java.net.URI; import java.net.URI;
import java.net.URISyntaxException; import java.net.URISyntaxException;
import java.util.List; import java.util.List;
import org.checkerframework.checker.nullness.qual.Nullable; import javax.annotation.Nullable;
final class NettyHttpClientAttributesExtractor final class NettyHttpClientAttributesExtractor
extends HttpClientAttributesExtractor<HttpRequestAndChannel, HttpResponse> { extends HttpClientAttributesExtractor<HttpRequestAndChannel, HttpResponse> {
@ -33,7 +33,8 @@ final class NettyHttpClientAttributesExtractor
} }
@Override @Override
protected @Nullable String url(HttpRequestAndChannel requestAndChannel) { @Nullable
protected String url(HttpRequestAndChannel requestAndChannel) {
try { try {
String hostHeader = getHost(requestAndChannel); String hostHeader = getHost(requestAndChannel);
String target = requestAndChannel.request().getUri(); String target = requestAndChannel.request().getUri();
@ -75,13 +76,15 @@ final class NettyHttpClientAttributesExtractor
} }
@Override @Override
protected @Nullable Long requestContentLength( @Nullable
protected Long requestContentLength(
HttpRequestAndChannel requestAndChannel, @Nullable HttpResponse response) { HttpRequestAndChannel requestAndChannel, @Nullable HttpResponse response) {
return null; return null;
} }
@Override @Override
protected @Nullable Long requestContentLengthUncompressed( @Nullable
protected Long requestContentLengthUncompressed(
HttpRequestAndChannel requestAndChannel, @Nullable HttpResponse response) { HttpRequestAndChannel requestAndChannel, @Nullable HttpResponse response) {
return null; return null;
} }
@ -92,13 +95,15 @@ final class NettyHttpClientAttributesExtractor
} }
@Override @Override
protected @Nullable Long responseContentLength( @Nullable
protected Long responseContentLength(
HttpRequestAndChannel requestAndChannel, HttpResponse response) { HttpRequestAndChannel requestAndChannel, HttpResponse response) {
return null; return null;
} }
@Override @Override
protected @Nullable Long responseContentLengthUncompressed( @Nullable
protected Long responseContentLengthUncompressed(
HttpRequestAndChannel requestAndChannel, HttpResponse response) { HttpRequestAndChannel requestAndChannel, HttpResponse response) {
return null; return null;
} }

View File

@ -10,13 +10,14 @@ import io.opentelemetry.instrumentation.api.instrumenter.net.InetSocketAddressNe
import io.opentelemetry.javaagent.instrumentation.netty.common.HttpRequestAndChannel; import io.opentelemetry.javaagent.instrumentation.netty.common.HttpRequestAndChannel;
import java.net.InetSocketAddress; import java.net.InetSocketAddress;
import java.net.SocketAddress; import java.net.SocketAddress;
import org.checkerframework.checker.nullness.qual.Nullable; import javax.annotation.Nullable;
final class NettyNetClientAttributesExtractor final class NettyNetClientAttributesExtractor
extends InetSocketAddressNetClientAttributesExtractor<HttpRequestAndChannel, HttpResponse> { extends InetSocketAddressNetClientAttributesExtractor<HttpRequestAndChannel, HttpResponse> {
@Override @Override
public @Nullable InetSocketAddress getAddress( @Nullable
public InetSocketAddress getAddress(
HttpRequestAndChannel requestAndChannel, @Nullable HttpResponse response) { HttpRequestAndChannel requestAndChannel, @Nullable HttpResponse response) {
SocketAddress address = requestAndChannel.channel().remoteAddress(); SocketAddress address = requestAndChannel.channel().remoteAddress();
if (address instanceof InetSocketAddress) { if (address instanceof InetSocketAddress) {
@ -26,7 +27,8 @@ final class NettyNetClientAttributesExtractor
} }
@Override @Override
public @Nullable String transport( @Nullable
public String transport(
HttpRequestAndChannel requestAndChannel, @Nullable HttpResponse response) { HttpRequestAndChannel requestAndChannel, @Nullable HttpResponse response) {
return null; return null;
} }