Package io.grpc.opentelemetry
Class OpenTelemetryTracingModule.ServerTracer
java.lang.Object
io.grpc.StreamTracer
io.grpc.ServerStreamTracer
io.grpc.opentelemetry.OpenTelemetryTracingModule.ServerTracer
- Enclosing class:
OpenTelemetryTracingModule
private final class OpenTelemetryTracingModule.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 int
private final io.opentelemetry.api.trace.Span
(package private) int
-
Constructor Summary
ConstructorsConstructorDescriptionServerTracer
(String fullMethodName, io.opentelemetry.api.trace.Span remoteSpan) -
Method Summary
Modifier and TypeMethodDescriptionio.grpc.Context
filterContext
(io.grpc.Context context) void
inboundMessage
(int seqNo) void
inboundMessageRead
(int seqNo, long optionalWireSize, long optionalUncompressedSize) void
inboundUncompressedSize
(long bytes) void
outboundMessageSent
(int seqNo, long optionalWireSize, long optionalUncompressedSize) 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
serverCallStarted, serverCallStarted
Methods inherited from class io.grpc.StreamTracer
inboundWireSize, outboundMessage, outboundUncompressedSize, outboundWireSize
-
Field Details
-
span
private final io.opentelemetry.api.trace.Span span -
streamClosed
volatile int streamClosed -
seqNo
private int seqNo
-
-
Constructor Details
-
ServerTracer
-
-
Method Details
-
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
-
filterContext
public io.grpc.Context filterContext(io.grpc.Context context) - Overrides:
filterContext
in classio.grpc.ServerStreamTracer
-
outboundMessageSent
public void outboundMessageSent(int seqNo, long optionalWireSize, long optionalUncompressedSize) - Overrides:
outboundMessageSent
in classio.grpc.StreamTracer
-
inboundMessageRead
public void inboundMessageRead(int seqNo, long optionalWireSize, long optionalUncompressedSize) - Overrides:
inboundMessageRead
in classio.grpc.StreamTracer
-
inboundMessage
public void inboundMessage(int seqNo) - Overrides:
inboundMessage
in classio.grpc.StreamTracer
-
inboundUncompressedSize
public void inboundUncompressedSize(long bytes) - Overrides:
inboundUncompressedSize
in classio.grpc.StreamTracer
-