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
-
-
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
All Methods Instance Methods Concrete Methods 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.
-
-
-
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 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
-
-