Class OpenTelemetryMetricsModule.CallAttemptsTracerFactory

java.lang.Object
io.grpc.ClientStreamTracer.Factory
io.grpc.opentelemetry.OpenTelemetryMetricsModule.CallAttemptsTracerFactory
Enclosing class:
OpenTelemetryMetricsModule

static final class OpenTelemetryMetricsModule.CallAttemptsTracerFactory extends io.grpc.ClientStreamTracer.Factory
  • Field Details

    • module

      private final OpenTelemetryMetricsModule module
    • target

      private final String target
    • attemptStopwatch

      private final com.google.common.base.Stopwatch attemptStopwatch
    • callStopWatch

      private final com.google.common.base.Stopwatch callStopWatch
    • callEnded

      private boolean callEnded
    • fullMethodName

      private final String fullMethodName
    • callPlugins

      private final List<OpenTelemetryPlugin.ClientCallPlugin> callPlugins
    • status

      private io.grpc.Status status
    • callLatencyNanos

      private long callLatencyNanos
    • lock

      private final Object lock
    • attemptsPerCall

      private final AtomicLong attemptsPerCall
    • activeStreams

      private int activeStreams
    • finishedCallToBeRecorded

      private boolean finishedCallToBeRecorded
  • Constructor Details

  • Method Details

    • newClientStreamTracer

      public io.grpc.ClientStreamTracer newClientStreamTracer(io.grpc.ClientStreamTracer.StreamInfo info, io.grpc.Metadata metadata)
      Overrides:
      newClientStreamTracer in class io.grpc.ClientStreamTracer.Factory
    • newClientTracer

      private OpenTelemetryMetricsModule.ClientTracer newClientTracer(io.grpc.ClientStreamTracer.StreamInfo info)
    • attemptEnded

      void attemptEnded()
    • callEnded

      void callEnded(io.grpc.Status status)
    • recordFinishedCall

      void recordFinishedCall()