|
61 | 61 | import io.grpc.opentelemetry.OpenTelemetryMetricsModule.CallAttemptsTracerFactory; |
62 | 62 | import io.grpc.opentelemetry.internal.OpenTelemetryConstants; |
63 | 63 | import io.grpc.stub.ClientCalls; |
| 64 | +import io.grpc.stub.StreamObserver; |
64 | 65 | import io.grpc.testing.GrpcCleanupRule; |
65 | 66 | import io.grpc.testing.GrpcServerRule; |
| 67 | +import io.grpc.testing.protobuf.SimpleRequest; |
| 68 | +import io.grpc.testing.protobuf.SimpleResponse; |
| 69 | +import io.grpc.testing.protobuf.SimpleServiceGrpc; |
66 | 70 | import io.opentelemetry.api.OpenTelemetry; |
67 | 71 | import io.opentelemetry.api.baggage.Baggage; |
68 | 72 | import io.opentelemetry.api.baggage.propagation.W3CBaggagePropagator; |
@@ -517,7 +521,7 @@ public void recordAttemptMetrics() { |
517 | 521 | enabledMetricsMap, disableDefaultMetrics); |
518 | 522 | OpenTelemetryMetricsModule module = newOpenTelemetryMetricsModule(resource); |
519 | 523 | OpenTelemetryMetricsModule.CallAttemptsTracerFactory callAttemptsTracerFactory = |
520 | | - new OpenTelemetryMetricsModule.CallAttemptsTracerFactory(module, target, CALL_OPTIONS |
| 524 | + new OpenTelemetryMetricsModule.CallAttemptsTracerFactory(module, target, CALL_OPTIONS, |
521 | 525 | method.getFullMethodName(), emptyList(), Context.root()); |
522 | 526 | ClientStreamTracer tracer = |
523 | 527 | callAttemptsTracerFactory.newClientStreamTracer(STREAM_INFO, new Metadata()); |
@@ -1536,7 +1540,7 @@ public void customLabel_present() { |
1536 | 1540 | emptyList()); |
1537 | 1541 | OpenTelemetryMetricsModule.CallAttemptsTracerFactory callAttemptsTracerFactory = |
1538 | 1542 | new CallAttemptsTracerFactory( |
1539 | | - module, target, callOptions, method.getFullMethodName(), emptyList()); |
| 1543 | + module, target, callOptions, method.getFullMethodName(), emptyList(), Context.root()); |
1540 | 1544 |
|
1541 | 1545 | ClientStreamTracer.StreamInfo streamInfo = |
1542 | 1546 | STREAM_INFO.toBuilder().setCallOptions(callOptions).build(); |
|
0 commit comments