Package io.grpc.xds.orca
Class OrcaOobUtil.OrcaReportingHelper.OrcaReportingState.OrcaReportingStream
java.lang.Object
io.grpc.ClientCall.Listener<OrcaLoadReport>
io.grpc.xds.orca.OrcaOobUtil.OrcaReportingHelper.OrcaReportingState.OrcaReportingStream
- Enclosing class:
OrcaOobUtil.OrcaReportingHelper.OrcaReportingState
private class OrcaOobUtil.OrcaReportingHelper.OrcaReportingState.OrcaReportingStream
extends io.grpc.ClientCall.Listener<OrcaLoadReport>
-
Field Summary
FieldsModifier and TypeFieldDescriptionprivate final io.grpc.ClientCall
<OrcaLoadReportRequest, OrcaLoadReport> private boolean
private final com.google.common.base.Stopwatch
-
Constructor Summary
ConstructorsConstructorDescriptionOrcaReportingStream
(io.grpc.Channel channel, com.google.common.base.Stopwatch stopwatch) -
Method Summary
Modifier and TypeMethodDescription(package private) void
(package private) void
handleResponse
(OrcaLoadReport response) (package private) void
handleStreamClosed
(io.grpc.Status status) void
onClose
(io.grpc.Status status, io.grpc.Metadata trailers) void
onMessage
(OrcaLoadReport response) (package private) void
start()
toString()
Methods inherited from class io.grpc.ClientCall.Listener
onHeaders, onReady
-
Field Details
-
call
-
stopwatch
private final com.google.common.base.Stopwatch stopwatch -
callHasResponded
private boolean callHasResponded
-
-
Constructor Details
-
OrcaReportingStream
OrcaReportingStream(io.grpc.Channel channel, com.google.common.base.Stopwatch stopwatch)
-
-
Method Details
-
start
void start() -
onMessage
- Overrides:
onMessage
in classio.grpc.ClientCall.Listener<OrcaLoadReport>
-
onClose
public void onClose(io.grpc.Status status, io.grpc.Metadata trailers) - Overrides:
onClose
in classio.grpc.ClientCall.Listener<OrcaLoadReport>
-
handleResponse
-
handleStreamClosed
void handleStreamClosed(io.grpc.Status status) -
cancel
-
toString
-