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

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()

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

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 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()