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

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

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

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 class ClientStreamTracer

inboundHeaders

public void inboundHeaders()

Description copied from class: ClientStreamTracer

Headers has been received from the server.

Overrides:

inboundHeaders in class ClientStreamTracer

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 class StreamTracer

Parameters:

seqNo - the sequential number of the message within the stream, starting from 0. It can be used to correlate with StreamTracer.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 class StreamTracer