add Nullaway to instrumentation API incubator

instrumentation-api-incubator/build.gradle.kts

@@ -6,6 +6,7 @@ plugins {
   id("otel.jacoco-conventions")
   id("otel.japicmp-conventions")
   id("otel.publish-conventions")
+  id("otel.nullaway-conventions")
 }
 
 group = "io.opentelemetry.instrumentation"

instrumentation-api-incubator/src/main/java/io/opentelemetry/instrumentation/api/incubator/builder/internal/DefaultHttpClientInstrumenterBuilder.java

@@ -71,7 +71,7 @@ private DefaultHttpClientInstrumenterBuilder(
       String instrumentationName,
       OpenTelemetry openTelemetry,
       HttpClientAttributesGetter<REQUEST, RESPONSE> attributesGetter,
-      TextMapSetter<REQUEST> headerSetter) {
+      @Nullable TextMapSetter<REQUEST> headerSetter) {
     this.instrumentationName = Objects.requireNonNull(instrumentationName, "instrumentationName");
     this.openTelemetry = Objects.requireNonNull(openTelemetry, "openTelemetry");
     this.attributesGetter = Objects.requireNonNull(attributesGetter, "attributesGetter");

instrumentation-api-incubator/src/main/java/io/opentelemetry/instrumentation/api/incubator/builder/internal/DefaultHttpServerInstrumenterBuilder.java

@@ -64,7 +64,7 @@ private DefaultHttpServerInstrumenterBuilder(
       String instrumentationName,
       OpenTelemetry openTelemetry,
       HttpServerAttributesGetter<REQUEST, RESPONSE> attributesGetter,
-      TextMapGetter<REQUEST> headerGetter) {
+      @Nullable TextMapGetter<REQUEST> headerGetter) {
     this.instrumentationName = Objects.requireNonNull(instrumentationName, "instrumentationName");
     this.openTelemetry = Objects.requireNonNull(openTelemetry, "openTelemetry");
     this.attributesGetter = Objects.requireNonNull(attributesGetter, "attributesGetter");

instrumentation-api-incubator/src/main/java/io/opentelemetry/instrumentation/api/incubator/config/internal/CommonConfig.java

@@ -17,8 +17,8 @@
 import java.util.HashSet;
 import java.util.List;
 import java.util.Set;
-import java.util.function.Function;
 import java.util.function.Supplier;
+import javax.annotation.Nullable;
 
 /**
  * This class is internal and is hence not for public use. Its APIs are unstable and can change at
@@ -41,6 +41,11 @@ public final class CommonConfig {
   private final String loggingSpanIdKey;
   private final String loggingTraceFlagsKey;
 
+  interface ValueProvider<T> {
+    @Nullable
+    T get(ConfigProvider configProvider);
+  }
+
   public CommonConfig(InstrumentationConfig config) {
     peerServiceResolver =
         PeerServiceResolver.create(
@@ -159,12 +164,12 @@ public String getTraceFlagsKey() {
 
   private static <T> T getFromConfigProviderOrFallback(
       InstrumentationConfig config,
-      Function<ConfigProvider, T> getFromConfigProvider,
+      ValueProvider<T> getFromConfigProvider,
       T defaultValue,
       Supplier<T> fallback) {
     ConfigProvider configProvider = config.getConfigProvider();
     if (configProvider != null) {
-      T value = getFromConfigProvider.apply(configProvider);
+      T value = getFromConfigProvider.get(configProvider);
       return value != null ? value : defaultValue;
     }
     // fallback doesn't return null, so we can safely call it

instrumentation-api-incubator/src/main/java/io/opentelemetry/instrumentation/api/incubator/semconv/db/DbClientSpanNameExtractor.java

@@ -8,6 +8,7 @@
 import io.opentelemetry.instrumentation.api.instrumenter.SpanNameExtractor;
 import io.opentelemetry.instrumentation.api.internal.SemconvStability;
 import java.util.Collection;
+import javax.annotation.Nullable;
 
 public abstract class DbClientSpanNameExtractor<REQUEST> implements SpanNameExtractor<REQUEST> {
 
@@ -42,7 +43,8 @@ public static <REQUEST> SpanNameExtractor<REQUEST> create(
 
   private DbClientSpanNameExtractor() {}
 
-  protected String computeSpanName(String dbName, String operation, String mainIdentifier) {
+  protected String computeSpanName(
+      @Nullable String dbName, @Nullable String operation, @Nullable String mainIdentifier) {
     if (operation == null) {
       return dbName == null ? DEFAULT_SPAN_NAME : dbName;
     }

instrumentation-api-incubator/src/main/java/io/opentelemetry/instrumentation/api/incubator/semconv/db/MultiQuery.java

@@ -8,14 +8,16 @@
 import java.util.Collection;
 import java.util.LinkedHashSet;
 import java.util.Set;
+import javax.annotation.Nullable;
 
 class MultiQuery {
 
-  private final String mainIdentifier;
-  private final String operation;
+  @Nullable private final String mainIdentifier;
+  @Nullable private final String operation;
   private final Set<String> statements;
 
-  private MultiQuery(String mainIdentifier, String operation, Set<String> statements) {
+  private MultiQuery(
+      @Nullable String mainIdentifier, @Nullable String operation, Set<String> statements) {
     this.mainIdentifier = mainIdentifier;
     this.operation = operation;
     this.statements = statements;
@@ -40,10 +42,12 @@ static MultiQuery analyze(
         uniqueMainIdentifier.getValue(), uniqueOperation.getValue(), uniqueStatements);
   }
 
+  @Nullable
   public String getMainIdentifier() {
     return mainIdentifier;
   }
 
+  @Nullable
   public String getOperation() {
     return operation;
   }
@@ -53,10 +57,10 @@ public Set<String> getStatements() {
   }
 
   private static class UniqueValue {
-    private String value;
+    @Nullable private String value;
     private boolean valid = true;
 
-    void set(String value) {
+    void set(@Nullable String value) {
       if (!valid) {
         return;
       }
@@ -67,6 +71,7 @@ void set(String value) {
       }
     }
 
+    @Nullable
     String getValue() {
       return valid ? value : null;
     }

instrumentation-api-incubator/src/main/java/io/opentelemetry/instrumentation/api/incubator/semconv/db/SqlClientAttributesGetter.java

@@ -8,6 +8,7 @@
 import java.util.Collection;
 import java.util.Collections;
 import java.util.Map;
+import javax.annotation.Nullable;
 
 /**
  * An interface for getting SQL database client attributes.
@@ -33,6 +34,7 @@ public interface SqlClientAttributesGetter<REQUEST, RESPONSE>
   Collection<String> getRawQueryTexts(REQUEST request);
 
   // TODO: make this required to implement
+  @Nullable
   default Long getBatchSize(REQUEST request) {
     return null;
   }

instrumentation-api-incubator/src/main/java/io/opentelemetry/instrumentation/api/incubator/semconv/db/SqlStatementSanitizer.java

@@ -51,7 +51,7 @@ public SqlStatementInfo sanitize(@Nullable String statement, SqlDialect dialect)
         CacheKey.create(statement, dialect), k -> sanitizeImpl(statement, dialect));
   }
 
-  private static SqlStatementInfo sanitizeImpl(@Nullable String statement, SqlDialect dialect) {
+  private static SqlStatementInfo sanitizeImpl(String statement, SqlDialect dialect) {
     supportability.incrementCounter(SQL_STATEMENT_SANITIZER_CACHE_MISS);
     return AutoSqlSanitizer.sanitize(statement, dialect);
   }

instrumentation-api-incubator/src/main/java/io/opentelemetry/instrumentation/api/incubator/semconv/genai/GenAiAttributesGetter.java

@@ -50,17 +50,17 @@ public interface GenAiAttributesGetter<REQUEST, RESPONSE> {
   @Nullable
   Double getRequestTopP(REQUEST request);
 
-  List<String> getResponseFinishReasons(REQUEST request, RESPONSE response);
+  List<String> getResponseFinishReasons(REQUEST request, @Nullable RESPONSE response);
 
   @Nullable
-  String getResponseId(REQUEST request, RESPONSE response);
+  String getResponseId(REQUEST request, @Nullable RESPONSE response);
 
   @Nullable
-  String getResponseModel(REQUEST request, RESPONSE response);
+  String getResponseModel(REQUEST request, @Nullable RESPONSE response);
 
   @Nullable
-  Long getUsageInputTokens(REQUEST request, RESPONSE response);
+  Long getUsageInputTokens(REQUEST request, @Nullable RESPONSE response);
 
   @Nullable
-  Long getUsageOutputTokens(REQUEST request, RESPONSE response);
+  Long getUsageOutputTokens(REQUEST request, @Nullable RESPONSE response);
 }

instrumentation-api-incubator/src/main/java/io/opentelemetry/instrumentation/api/incubator/semconv/http/HttpClientPeerServiceAttributesExtractor.java

@@ -76,7 +76,7 @@ public void onEnd(
 
   @Nullable
   private String mapToPeerService(
-      @Nullable String host, @Nullable Integer port, @Nullable Supplier<String> pathSupplier) {
+      @Nullable String host, @Nullable Integer port, Supplier<String> pathSupplier) {
     if (host == null) {
       return null;
     }

instrumentation-api-incubator/src/main/java/io/opentelemetry/instrumentation/api/incubator/semconv/messaging/MessagingAttributesExtractor.java

@@ -141,6 +141,7 @@ public void onEnd(
    * any time.
    */
   @Override
+  @Nullable
   public SpanKey internalGetSpanKey() {
     if (operation == null) {
       return null;

instrumentation-api-incubator/src/main/java/io/opentelemetry/instrumentation/api/incubator/semconv/net/PeerServiceAttributesExtractor.java

@@ -72,6 +72,6 @@ private String mapToPeerService(@Nullable String host, @Nullable Integer port) {
     if (host == null) {
       return null;
     }
-    return peerServiceResolver.resolveService(host, port, null);
+    return peerServiceResolver.resolveService(host, port, () -> null);
   }
 }

instrumentation-api-incubator/src/main/java/io/opentelemetry/instrumentation/api/incubator/semconv/net/PeerServiceResolver.java

@@ -14,8 +14,7 @@ public interface PeerServiceResolver {
   public boolean isEmpty();
 
   @Nullable
-  public String resolveService(
-      String host, @Nullable Integer port, @Nullable Supplier<String> pathSupplier);
+  public String resolveService(String host, @Nullable Integer port, Supplier<String> pathSupplier);
 
   static PeerServiceResolver create(Map<String, String> mapping) {
     return new PeerServiceResolverImpl(mapping);

instrumentation-api-incubator/src/main/java/io/opentelemetry/instrumentation/api/incubator/semconv/net/PeerServiceResolverImpl.java

@@ -46,8 +46,7 @@ public boolean isEmpty() {
 
   @Override
   @Nullable
-  public String resolveService(
-      String host, @Nullable Integer port, @Nullable Supplier<String> pathSupplier) {
+  public String resolveService(String host, @Nullable Integer port, Supplier<String> pathSupplier) {
     Map<ServiceMatcher, String> matchers = mapping.get(host);
     if (matchers == null) {
       return null;
@@ -62,7 +61,7 @@ public String resolveService(
   @AutoValue
   abstract static class ServiceMatcher {
 
-    static ServiceMatcher create(Integer port, String path) {
+    static ServiceMatcher create(@Nullable Integer port, @Nullable String path) {
       return new AutoValue_PeerServiceResolverImpl_ServiceMatcher(port, path);
     }
 
@@ -72,16 +71,13 @@ static ServiceMatcher create(Integer port, String path) {
     @Nullable
     abstract String getPath();
 
-    public boolean matches(Integer port, Supplier<String> pathSupplier) {
+    public boolean matches(@Nullable Integer port, Supplier<String> pathSupplier) {
       if (this.getPort() != null) {
         if (!this.getPort().equals(port)) {
           return false;
         }
       }
       if (this.getPath() != null && this.getPath().length() > 0) {
-        if (pathSupplier == null) {
-          return false;
-        }
         String path = pathSupplier.get();
         if (path == null) {
           return false;