Package io.grpc.opentelemetry
Class OpenTelemetryTracingModule.ClientTracer
java.lang.Object
io.grpc.StreamTracer
io.grpc.ClientStreamTracer
io.grpc.opentelemetry.OpenTelemetryTracingModule.ClientTracer
- Enclosing class:
OpenTelemetryTracingModule
private final class OpenTelemetryTracingModule.ClientTracer
extends io.grpc.ClientStreamTracer
-
Nested Class Summary
Nested classes/interfaces inherited from class io.grpc.ClientStreamTracer
io.grpc.ClientStreamTracer.Factory, io.grpc.ClientStreamTracer.StreamInfo
-
Field Summary
FieldsModifier and TypeFieldDescription(package private) boolean
private final io.opentelemetry.api.trace.Span
(package private) int
private final io.opentelemetry.api.trace.Span
Fields inherited from class io.grpc.ClientStreamTracer
NAME_RESOLUTION_DELAYED
-
Constructor Summary
ConstructorsConstructorDescriptionClientTracer
(io.opentelemetry.api.trace.Span span, io.opentelemetry.api.trace.Span parentSpan) -
Method Summary
Modifier and TypeMethodDescriptionvoid
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) void
streamCreated
(io.grpc.Attributes transportAtts, io.grpc.Metadata headers) Methods inherited from class io.grpc.ClientStreamTracer
addOptionalLabel, inboundHeaders, inboundHeaders, inboundTrailers, outboundHeaders
Methods inherited from class io.grpc.StreamTracer
inboundWireSize, outboundMessage, outboundUncompressedSize, outboundWireSize
-
Field Details
-
span
private final io.opentelemetry.api.trace.Span span -
parentSpan
private final io.opentelemetry.api.trace.Span parentSpan -
seqNo
volatile int seqNo -
isPendingStream
boolean isPendingStream
-
-
Constructor Details
-
ClientTracer
ClientTracer(io.opentelemetry.api.trace.Span span, io.opentelemetry.api.trace.Span parentSpan)
-
-
Method Details
-
streamCreated
public void streamCreated(io.grpc.Attributes transportAtts, io.grpc.Metadata headers) - Overrides:
streamCreated
in classio.grpc.ClientStreamTracer
-
createPendingStream
public void createPendingStream()- Overrides:
createPendingStream
in classio.grpc.ClientStreamTracer
-
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
-
streamClosed
public void streamClosed(io.grpc.Status status) - Overrides:
streamClosed
in classio.grpc.StreamTracer
-