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

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

Fields inherited from class io.grpc.ClientStreamTracer

NAME_RESOLUTION_DELAYED

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

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

Methods inherited from class io.grpc.StreamTracer

inboundMessage, inboundMessageRead, inboundUncompressedSize, outboundMessage, outboundMessageSent, outboundUncompressedSize

Methods inherited from class java.lang.Object

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

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 class io.grpc.ClientStreamTracer

outboundWireSize

public void outboundWireSize(long bytes)

Overrides:

outboundWireSize in class io.grpc.StreamTracer

inboundWireSize

public void inboundWireSize(long bytes)

Overrides:

inboundWireSize in class io.grpc.StreamTracer

addOptionalLabel

public void addOptionalLabel(java.lang.String key,
                             java.lang.String value)

Overrides:

addOptionalLabel in class io.grpc.ClientStreamTracer

inboundTrailers

public void inboundTrailers(io.grpc.Metadata trailers)

Overrides:

inboundTrailers in class io.grpc.ClientStreamTracer

streamClosed

public void streamClosed(io.grpc.Status status)

Overrides:

streamClosed in class io.grpc.StreamTracer

recordFinishedAttempt

void recordFinishedAttempt()