Package io.grpc.opentelemetry

Class OpenTelemetryMetricsModule.ServerTracer

java.lang.Object

io.grpc.StreamTracer

io.grpc.ServerStreamTracer

io.grpc.opentelemetry.OpenTelemetryMetricsModule.ServerTracer

Enclosing class:

OpenTelemetryMetricsModule

private static final class OpenTelemetryMetricsModule.ServerTracer
extends io.grpc.ServerStreamTracer

Nested Class Summary

Nested classes/interfaces inherited from class io.grpc.ServerStreamTracer

io.grpc.ServerStreamTracer.Factory, io.grpc.ServerStreamTracer.ServerCallInfo<ReqT extends java.lang.Object,RespT extends java.lang.Object>

Field Summary

Fields

Modifier and Type	Field	Description
private java.lang.String	fullMethodName
private long	inboundWireSize
private static java.util.concurrent.atomic.AtomicLongFieldUpdater<OpenTelemetryMetricsModule.ServerTracer>	inboundWireSizeUpdater
private boolean	isGeneratedMethod
private OpenTelemetryMetricsModule	module
private long	outboundWireSize
private static java.util.concurrent.atomic.AtomicLongFieldUpdater<OpenTelemetryMetricsModule.ServerTracer>	outboundWireSizeUpdater
private com.google.common.base.Stopwatch	stopwatch
private int	streamClosed
private static java.util.concurrent.atomic.AtomicIntegerFieldUpdater<OpenTelemetryMetricsModule.ServerTracer>	streamClosedUpdater
private java.util.List<OpenTelemetryPlugin.ServerStreamPlugin>	streamPlugins

Constructor Summary

Constructors

Constructor	Description
ServerTracer(OpenTelemetryMetricsModule module, java.lang.String fullMethodName, java.util.List<OpenTelemetryPlugin.ServerStreamPlugin> streamPlugins)

Method Summary

Modifier and Type	Method	Description
void	inboundWireSize(long bytes)
void	outboundWireSize(long bytes)
void	serverCallStarted(io.grpc.ServerStreamTracer.ServerCallInfo<?,?> callInfo)
void	streamClosed(io.grpc.Status status)	Record a finished stream and mark the current time as the end time.

Methods inherited from class io.grpc.ServerStreamTracer

filterContext, serverCallStarted

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

streamClosedUpdater

@Nullable
private static final java.util.concurrent.atomic.AtomicIntegerFieldUpdater<OpenTelemetryMetricsModule.ServerTracer> streamClosedUpdater

outboundWireSizeUpdater

@Nullable
private static final java.util.concurrent.atomic.AtomicLongFieldUpdater<OpenTelemetryMetricsModule.ServerTracer> outboundWireSizeUpdater

inboundWireSizeUpdater

@Nullable
private static final java.util.concurrent.atomic.AtomicLongFieldUpdater<OpenTelemetryMetricsModule.ServerTracer> inboundWireSizeUpdater

module

private final OpenTelemetryMetricsModule module

fullMethodName

private final java.lang.String fullMethodName

streamPlugins

private final java.util.List<OpenTelemetryPlugin.ServerStreamPlugin> streamPlugins

isGeneratedMethod

private volatile boolean isGeneratedMethod

streamClosed

private volatile int streamClosed

stopwatch

private final com.google.common.base.Stopwatch stopwatch

outboundWireSize

private volatile long outboundWireSize

inboundWireSize

private volatile long inboundWireSize

Constructor Detail

ServerTracer

ServerTracer(OpenTelemetryMetricsModule module,
             java.lang.String fullMethodName,
             java.util.List<OpenTelemetryPlugin.ServerStreamPlugin> streamPlugins)

Method Detail

serverCallStarted

public void serverCallStarted(io.grpc.ServerStreamTracer.ServerCallInfo<?,?> callInfo)

Overrides:

serverCallStarted in class io.grpc.ServerStreamTracer

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

streamClosed

public void streamClosed(io.grpc.Status status)

Record a finished stream and mark the current time as the end time.

Can be called from any thread without synchronization. Calling it the second time or more is a no-op.

Overrides:

streamClosed in class io.grpc.StreamTracer