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
-
-
Field Summary
Fields Modifier and Type Field Description private int
seqNo
private io.opentelemetry.api.trace.Span
span
(package private) int
streamClosed
-
Constructor Summary
Constructors Constructor Description ServerTracer(java.lang.String fullMethodName, io.opentelemetry.api.trace.Span remoteSpan)
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description io.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.
-
-
-
Method Detail
-
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
-
-