Package io.grpc.opentelemetry
Class OpenTelemetryMetricsModule.ClientTracer
- java.lang.Object
-
- io.grpc.StreamTracer
-
- io.grpc.ClientStreamTracer
-
- io.grpc.opentelemetry.OpenTelemetryMetricsModule.ClientTracer
-
- Enclosing class:
- OpenTelemetryMetricsModule
private static final class OpenTelemetryMetricsModule.ClientTracer extends io.grpc.ClientStreamTracer
-
-
Field Summary
Fields Modifier and Type Field Description (package private) long
attemptNanos
(package private) OpenTelemetryMetricsModule.CallAttemptsTracerFactory
attemptsState
(package private) java.lang.String
fullMethodName
(package private) long
inboundWireSize
private static java.util.concurrent.atomic.AtomicLongFieldUpdater<OpenTelemetryMetricsModule.ClientTracer>
inboundWireSizeUpdater
(package private) io.grpc.ClientStreamTracer.StreamInfo
info
(package private) java.lang.String
locality
(package private) OpenTelemetryMetricsModule
module
(package private) long
outboundWireSize
private static java.util.concurrent.atomic.AtomicLongFieldUpdater<OpenTelemetryMetricsModule.ClientTracer>
outboundWireSizeUpdater
(package private) io.grpc.Status.Code
statusCode
(package private) com.google.common.base.Stopwatch
stopwatch
(package private) java.util.List<OpenTelemetryPlugin.ClientStreamPlugin>
streamPlugins
(package private) java.lang.String
target
-
Constructor Summary
Constructors Constructor Description ClientTracer(OpenTelemetryMetricsModule.CallAttemptsTracerFactory attemptsState, OpenTelemetryMetricsModule module, io.grpc.ClientStreamTracer.StreamInfo info, java.lang.String target, java.lang.String fullMethodName, java.util.List<OpenTelemetryPlugin.ClientStreamPlugin> streamPlugins)
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description void
addOptionalLabel(java.lang.String key, java.lang.String value)
void
inboundHeaders(io.grpc.Metadata headers)
void
inboundTrailers(io.grpc.Metadata trailers)
void
inboundWireSize(long bytes)
void
outboundWireSize(long bytes)
(package private) void
recordFinishedAttempt()
void
streamClosed(io.grpc.Status status)
-
Methods inherited from class io.grpc.ClientStreamTracer
createPendingStream, inboundHeaders, outboundHeaders, streamCreated
-
-
-
-
Field Detail
-
outboundWireSizeUpdater
@Nullable private static final java.util.concurrent.atomic.AtomicLongFieldUpdater<OpenTelemetryMetricsModule.ClientTracer> outboundWireSizeUpdater
-
inboundWireSizeUpdater
@Nullable private static final java.util.concurrent.atomic.AtomicLongFieldUpdater<OpenTelemetryMetricsModule.ClientTracer> inboundWireSizeUpdater
-
stopwatch
final com.google.common.base.Stopwatch stopwatch
-
attemptsState
final OpenTelemetryMetricsModule.CallAttemptsTracerFactory attemptsState
-
module
final OpenTelemetryMetricsModule module
-
info
final io.grpc.ClientStreamTracer.StreamInfo info
-
target
final java.lang.String target
-
fullMethodName
final java.lang.String fullMethodName
-
streamPlugins
final java.util.List<OpenTelemetryPlugin.ClientStreamPlugin> streamPlugins
-
outboundWireSize
volatile long outboundWireSize
-
inboundWireSize
volatile long inboundWireSize
-
locality
volatile java.lang.String locality
-
attemptNanos
long attemptNanos
-
statusCode
io.grpc.Status.Code statusCode
-
-
Constructor Detail
-
ClientTracer
ClientTracer(OpenTelemetryMetricsModule.CallAttemptsTracerFactory attemptsState, OpenTelemetryMetricsModule module, io.grpc.ClientStreamTracer.StreamInfo info, java.lang.String target, java.lang.String fullMethodName, java.util.List<OpenTelemetryPlugin.ClientStreamPlugin> streamPlugins)
-
-
Method Detail
-
inboundHeaders
public void inboundHeaders(io.grpc.Metadata headers)
- Overrides:
inboundHeaders
in classio.grpc.ClientStreamTracer
-
outboundWireSize
public void outboundWireSize(long bytes)
- Overrides:
outboundWireSize
in classio.grpc.StreamTracer
-
inboundWireSize
public void inboundWireSize(long bytes)
- Overrides:
inboundWireSize
in classio.grpc.StreamTracer
-
addOptionalLabel
public void addOptionalLabel(java.lang.String key, java.lang.String value)
- Overrides:
addOptionalLabel
in classio.grpc.ClientStreamTracer
-
inboundTrailers
public void inboundTrailers(io.grpc.Metadata trailers)
- Overrides:
inboundTrailers
in classio.grpc.ClientStreamTracer
-
streamClosed
public void streamClosed(io.grpc.Status status)
- Overrides:
streamClosed
in classio.grpc.StreamTracer
-
recordFinishedAttempt
void recordFinishedAttempt()
-
-