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,RespT>

Field Summary

Fields

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

Constructor Summary

Constructors

Constructor	Description
ServerTracer(OpenTelemetryMetricsModule module, String fullMethodName, 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 Details

streamClosedUpdater

@Nullable
private static final AtomicIntegerFieldUpdater<OpenTelemetryMetricsModule.ServerTracer> streamClosedUpdater

outboundWireSizeUpdater

@Nullable
private static final AtomicLongFieldUpdater<OpenTelemetryMetricsModule.ServerTracer> outboundWireSizeUpdater

inboundWireSizeUpdater

@Nullable
private static final AtomicLongFieldUpdater<OpenTelemetryMetricsModule.ServerTracer> inboundWireSizeUpdater

module

private final OpenTelemetryMetricsModule module

fullMethodName

private final String fullMethodName

streamPlugins

private final 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 Details

ServerTracer

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

Method Details

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