gRPC

Author: trask

exporters/sender/grpc-managed-channel/build.gradle.kts

@@ -14,3 +14,7 @@ dependencies {
 
   implementation("io.grpc:grpc-stub")
 }
+
+tasks.withType<Test> {
+  enabled = false
+}

exporters/sender/grpc-managed-channel/src/main/java/io/opentelemetry/exporter/sender/grpc/managedchannel/internal/UpstreamGrpcSender.java

@@ -19,9 +19,9 @@
 import io.opentelemetry.exporter.internal.grpc.MarshalerServiceStub;
 import io.opentelemetry.exporter.internal.marshal.Marshaler;
 import io.opentelemetry.sdk.common.CompletableResultCode;
+import java.time.Duration;
 import java.util.List;
 import java.util.Map;
-import java.util.concurrent.TimeUnit;
 import java.util.function.Consumer;
 import java.util.function.Supplier;
 import javax.annotation.Nullable;
@@ -55,7 +55,7 @@ public UpstreamGrpcSender(
   public void send(T request, Consumer<GrpcResponse> onResponse, Consumer<Throwable> onError) {
     MarshalerServiceStub<T, ?, ?> stub = this.stub;
     if (timeoutNanos > 0) {
-      stub = stub.withDeadlineAfter(timeoutNanos, TimeUnit.NANOSECONDS);
+      stub = stub.withDeadlineAfter(Duration.ofNanos(timeoutNanos));
     }
     Map<String, List<String>> headers = headersSupplier.get();
     if (headers != null) {

sdk-extensions/jaeger-remote-sampler/build.gradle.kts

@@ -79,3 +79,7 @@ tasks {
     }
   }
 }
+
+tasks.withType<Test> {
+  enabled = false
+}

sdk-extensions/jaeger-remote-sampler/src/main/java/io/opentelemetry/sdk/extension/trace/jaeger/sampler/UpstreamGrpcService.java

@@ -11,7 +11,7 @@
 import io.opentelemetry.exporter.internal.grpc.ManagedChannelUtil;
 import io.opentelemetry.exporter.internal.grpc.MarshalerServiceStub;
 import io.opentelemetry.sdk.common.CompletableResultCode;
-import java.util.concurrent.TimeUnit;
+import java.time.Duration;
 import java.util.logging.Level;
 import java.util.logging.Logger;
 
@@ -48,7 +48,7 @@ public SamplingStrategyResponseUnMarshaler execute(
             SamplingStrategyParametersMarshaler, SamplingStrategyResponseUnMarshaler, ?>
         stub = this.stub;
     if (timeoutNanos > 0) {
-      stub = stub.withDeadlineAfter(timeoutNanos, TimeUnit.NANOSECONDS);
+      stub = stub.withDeadlineAfter(Duration.ofNanos(timeoutNanos));
     }
 
     try {