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
-
Nested Class Summary
Nested classes/interfaces inherited from class io.grpc.ClientStreamTracer
io.grpc.ClientStreamTracer.Factory, io.grpc.ClientStreamTracer.StreamInfo
-
Field Summary
FieldsModifier and TypeFieldDescription(package private) long
(package private) final OpenTelemetryMetricsModule.CallAttemptsTracerFactory
(package private) final String
(package private) long
private static final AtomicLongFieldUpdater
<OpenTelemetryMetricsModule.ClientTracer> (package private) final io.grpc.ClientStreamTracer.StreamInfo
(package private) String
(package private) final OpenTelemetryMetricsModule
(package private) long
private static final AtomicLongFieldUpdater
<OpenTelemetryMetricsModule.ClientTracer> (package private) io.grpc.Status.Code
(package private) final com.google.common.base.Stopwatch
(package private) final List
<OpenTelemetryPlugin.ClientStreamPlugin> (package private) final String
Fields inherited from class io.grpc.ClientStreamTracer
NAME_RESOLUTION_DELAYED
-
Constructor Summary
ConstructorsConstructorDescriptionClientTracer
(OpenTelemetryMetricsModule.CallAttemptsTracerFactory attemptsState, OpenTelemetryMetricsModule module, io.grpc.ClientStreamTracer.StreamInfo info, String target, String fullMethodName, List<OpenTelemetryPlugin.ClientStreamPlugin> streamPlugins) -
Method Summary
Modifier and TypeMethodDescriptionvoid
addOptionalLabel
(String key, 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
void
streamClosed
(io.grpc.Status status) Methods inherited from class io.grpc.ClientStreamTracer
createPendingStream, inboundHeaders, outboundHeaders, streamCreated
Methods inherited from class io.grpc.StreamTracer
inboundMessage, inboundMessageRead, inboundUncompressedSize, outboundMessage, outboundMessageSent, outboundUncompressedSize
-
Field Details
-
outboundWireSizeUpdater
@Nullable private static final AtomicLongFieldUpdater<OpenTelemetryMetricsModule.ClientTracer> outboundWireSizeUpdater -
inboundWireSizeUpdater
@Nullable private static final AtomicLongFieldUpdater<OpenTelemetryMetricsModule.ClientTracer> inboundWireSizeUpdater -
stopwatch
final com.google.common.base.Stopwatch stopwatch -
attemptsState
-
module
-
info
final io.grpc.ClientStreamTracer.StreamInfo info -
target
-
fullMethodName
-
streamPlugins
-
outboundWireSize
volatile long outboundWireSize -
inboundWireSize
volatile long inboundWireSize -
locality
-
attemptNanos
long attemptNanos -
statusCode
io.grpc.Status.Code statusCode
-
-
Constructor Details
-
ClientTracer
ClientTracer(OpenTelemetryMetricsModule.CallAttemptsTracerFactory attemptsState, OpenTelemetryMetricsModule module, io.grpc.ClientStreamTracer.StreamInfo info, String target, String fullMethodName, List<OpenTelemetryPlugin.ClientStreamPlugin> streamPlugins)
-
-
Method Details
-
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
- 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()
-