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
-
-
Field Summary
Fields Modifier and Type Field Description (package private) boolean
isPendingStream
private io.opentelemetry.api.trace.Span
parentSpan
(package private) int
seqNo
private io.opentelemetry.api.trace.Span
span
-
Constructor Summary
Constructors Constructor Description ClientTracer(io.opentelemetry.api.trace.Span span, io.opentelemetry.api.trace.Span parentSpan)
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description void
createPendingStream()
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
-
-
-
-
Method Detail
-
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
-
-