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
FieldsModifier and TypeFieldDescriptionprivate final String
private long
private static final AtomicLongFieldUpdater
<OpenTelemetryMetricsModule.ServerTracer> private boolean
private final OpenTelemetryMetricsModule
private long
private static final AtomicLongFieldUpdater
<OpenTelemetryMetricsModule.ServerTracer> private final com.google.common.base.Stopwatch
private int
private static final AtomicIntegerFieldUpdater
<OpenTelemetryMetricsModule.ServerTracer> private final List
<OpenTelemetryPlugin.ServerStreamPlugin> -
Constructor Summary
ConstructorsConstructorDescriptionServerTracer
(OpenTelemetryMetricsModule module, String fullMethodName, List<OpenTelemetryPlugin.ServerStreamPlugin> streamPlugins) -
Method Summary
Modifier and TypeMethodDescriptionvoid
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
-
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
-
fullMethodName
-
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 classio.grpc.ServerStreamTracer
-
outboundWireSize
public void outboundWireSize(long bytes) - Overrides:
outboundWireSize
in classio.grpc.StreamTracer
-
inboundWireSize
public void inboundWireSize(long bytes) - Overrides:
inboundWireSize
in classio.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 classio.grpc.StreamTracer
-