Package io.grpc.grpclb
Class GrpclbClientLoadRecorder.StreamTracer
java.lang.Object
io.grpc.StreamTracer
io.grpc.ClientStreamTracer
io.grpc.grpclb.GrpclbClientLoadRecorder.StreamTracer
- Enclosing class:
GrpclbClientLoadRecorder
-
Nested Class Summary
Nested classes/interfaces inherited from class io.grpc.ClientStreamTracer
ClientStreamTracer.Factory, ClientStreamTracer.StreamInfo
-
Field Summary
FieldsFields inherited from class io.grpc.ClientStreamTracer
NAME_RESOLUTION_DELAYED
-
Constructor Summary
Constructors -
Method Summary
Modifier and TypeMethodDescriptionvoid
Headers has been received from the server.void
inboundMessage
(int seqNo) An inbound message has been received by the stream.void
Headers has been sent to the socket.void
streamClosed
(Status status) Stream is closed.Methods inherited from class io.grpc.ClientStreamTracer
addOptionalLabel, createPendingStream, inboundHeaders, inboundTrailers, streamCreated
Methods inherited from class io.grpc.StreamTracer
inboundMessageRead, inboundUncompressedSize, inboundWireSize, outboundMessage, outboundMessageSent, outboundUncompressedSize, outboundWireSize
-
Field Details
-
headersSent
private volatile boolean headersSent -
anythingReceived
private volatile boolean anythingReceived
-
-
Constructor Details
-
StreamTracer
private StreamTracer()
-
-
Method Details
-
outboundHeaders
public void outboundHeaders()Description copied from class:ClientStreamTracer
Headers has been sent to the socket.- Overrides:
outboundHeaders
in classClientStreamTracer
-
inboundHeaders
public void inboundHeaders()Description copied from class:ClientStreamTracer
Headers has been received from the server.- Overrides:
inboundHeaders
in classClientStreamTracer
-
inboundMessage
public void inboundMessage(int seqNo) Description copied from class:StreamTracer
An inbound message has been received by the stream. This is called as soon as the stream knows about the message, but doesn't have further guarantee such as whether the message is deserialized or not.- Overrides:
inboundMessage
in classStreamTracer
- Parameters:
seqNo
- the sequential number of the message within the stream, starting from 0. It can be used to correlate withStreamTracer.inboundMessageRead(int, long, long)
for the same message.
-
streamClosed
Description copied from class:StreamTracer
Stream is closed. This will be called exactly once.- Overrides:
streamClosed
in classStreamTracer
-