Package io.grpc.opentelemetry
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 Summary
Fields Modifier and Type Field Description private int
activeStreams
private java.util.concurrent.atomic.AtomicLong
attemptsPerCall
private com.google.common.base.Stopwatch
attemptStopwatch
private boolean
callEnded
private long
callLatencyNanos
private java.util.List<OpenTelemetryPlugin.ClientCallPlugin>
callPlugins
private com.google.common.base.Stopwatch
callStopWatch
private boolean
finishedCallToBeRecorded
private java.lang.String
fullMethodName
private java.lang.Object
lock
private OpenTelemetryMetricsModule
module
private io.grpc.Status
status
private java.lang.String
target
-
Constructor Summary
Constructors Constructor Description CallAttemptsTracerFactory(OpenTelemetryMetricsModule module, java.lang.String target, java.lang.String fullMethodName, java.util.List<OpenTelemetryPlugin.ClientCallPlugin> callPlugins)
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description (package private) void
attemptEnded()
(package private) void
callEnded(io.grpc.Status status)
io.grpc.ClientStreamTracer
newClientStreamTracer(io.grpc.ClientStreamTracer.StreamInfo info, io.grpc.Metadata metadata)
private OpenTelemetryMetricsModule.ClientTracer
newClientTracer(io.grpc.ClientStreamTracer.StreamInfo info)
(package private) void
recordFinishedCall()
-
-
-
Field Detail
-
module
private final OpenTelemetryMetricsModule module
-
target
private final java.lang.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 java.lang.String fullMethodName
-
callPlugins
private final java.util.List<OpenTelemetryPlugin.ClientCallPlugin> callPlugins
-
status
private io.grpc.Status status
-
callLatencyNanos
private long callLatencyNanos
-
lock
private final java.lang.Object lock
-
attemptsPerCall
private final java.util.concurrent.atomic.AtomicLong attemptsPerCall
-
activeStreams
private int activeStreams
-
finishedCallToBeRecorded
private boolean finishedCallToBeRecorded
-
-
Constructor Detail
-
CallAttemptsTracerFactory
CallAttemptsTracerFactory(OpenTelemetryMetricsModule module, java.lang.String target, java.lang.String fullMethodName, java.util.List<OpenTelemetryPlugin.ClientCallPlugin> callPlugins)
-
-
Method Detail
-
newClientStreamTracer
public io.grpc.ClientStreamTracer newClientStreamTracer(io.grpc.ClientStreamTracer.StreamInfo info, io.grpc.Metadata metadata)
- Overrides:
newClientStreamTracer
in classio.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()
-
-