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 final AtomicLong	attemptsPerCall
private final com.google.common.base.Stopwatch	attemptStopwatch
private boolean	callEnded
private long	callLatencyNanos
private final List<OpenTelemetryPlugin.ClientCallPlugin>	callPlugins
private final com.google.common.base.Stopwatch	callStopWatch
private boolean	finishedCallToBeRecorded
private final String	fullMethodName
private final Object	lock
private final OpenTelemetryMetricsModule	module
private io.grpc.Status	status
private final String	target

Constructor Summary

Constructors

Constructor	Description
CallAttemptsTracerFactory(OpenTelemetryMetricsModule module, String target, String fullMethodName, 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 Object

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

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

CallAttemptsTracerFactory

CallAttemptsTracerFactory(OpenTelemetryMetricsModule module,
 String target,
 String fullMethodName,
 List<OpenTelemetryPlugin.ClientCallPlugin> callPlugins)

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