Package io.grpc.grpclb
Class GrpclbClientLoadRecorder.StreamTracer
- java.lang.Object
-
- io.grpc.StreamTracer
-
- io.grpc.ClientStreamTracer
-
- io.grpc.grpclb.GrpclbClientLoadRecorder.StreamTracer
-
- Enclosing class:
- GrpclbClientLoadRecorder
private class GrpclbClientLoadRecorder.StreamTracer extends ClientStreamTracer
-
-
Nested Class Summary
-
Nested classes/interfaces inherited from class io.grpc.ClientStreamTracer
ClientStreamTracer.Factory, ClientStreamTracer.StreamInfo
-
-
Field Summary
Fields Modifier and Type Field Description private boolean
anythingReceived
private boolean
headersSent
-
Fields inherited from class io.grpc.ClientStreamTracer
NAME_RESOLUTION_DELAYED
-
-
Constructor Summary
Constructors Modifier Constructor Description private
StreamTracer()
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description void
inboundHeaders()
Headers has been received from the server.void
inboundMessage(int seqNo)
An inbound message has been received by the stream.void
outboundHeaders()
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
-
-
-
-
Method Detail
-
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
public void streamClosed(Status status)
Description copied from class:StreamTracer
Stream is closed. This will be called exactly once.- Overrides:
streamClosed
in classStreamTracer
-
-