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) final OpenTelemetryMetricsModule.CallAttemptsTracerFactory	attemptsState
(package private) final String	fullMethodName
(package private) long	inboundWireSize
private static final AtomicLongFieldUpdater<OpenTelemetryMetricsModule.ClientTracer>	inboundWireSizeUpdater
(package private) final io.grpc.ClientStreamTracer.StreamInfo	info
(package private) String	locality
(package private) final OpenTelemetryMetricsModule	module
(package private) long	outboundWireSize
private static final AtomicLongFieldUpdater<OpenTelemetryMetricsModule.ClientTracer>	outboundWireSizeUpdater
(package private) io.grpc.Status.Code	statusCode
(package private) final com.google.common.base.Stopwatch	stopwatch
(package private) final List<OpenTelemetryPlugin.ClientStreamPlugin>	streamPlugins
(package private) final 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, String target, String fullMethodName, List<OpenTelemetryPlugin.ClientStreamPlugin> streamPlugins)

Method Summary

Modifier and Type	Method	Description
void	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	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 Object

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

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

final OpenTelemetryMetricsModule.CallAttemptsTracerFactory attemptsState

module

final OpenTelemetryMetricsModule module

info

final io.grpc.ClientStreamTracer.StreamInfo info

target

final String target

fullMethodName

final String fullMethodName

streamPlugins

final List<OpenTelemetryPlugin.ClientStreamPlugin> streamPlugins

outboundWireSize

volatile long outboundWireSize

inboundWireSize

volatile long inboundWireSize

locality

volatile String 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 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(String key,
 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()