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
Fields Modifier and Type Field Description private io.grpc.ClientCall<OrcaLoadReportRequest,OrcaLoadReport>callprivate booleancallHasRespondedprivate com.google.common.base.Stopwatchstopwatch
-
Constructor Summary
Constructors Constructor Description OrcaReportingStream(io.grpc.Channel channel, com.google.common.base.Stopwatch stopwatch)
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description (package private) voidcancel(java.lang.String msg)(package private) voidhandleResponse(OrcaLoadReport response)(package private) voidhandleStreamClosed(io.grpc.Status status)voidonClose(io.grpc.Status status, io.grpc.Metadata trailers)voidonMessage(OrcaLoadReport response)(package private) voidstart()java.lang.StringtoString()
-
-
-
Field Detail
-
call
private final io.grpc.ClientCall<OrcaLoadReportRequest,OrcaLoadReport> call
-
stopwatch
private final com.google.common.base.Stopwatch stopwatch
-
callHasResponded
private boolean callHasResponded
-
-
Method Detail
-
start
void start()
-
onMessage
public void onMessage(OrcaLoadReport response)
- Overrides:
onMessagein classio.grpc.ClientCall.Listener<OrcaLoadReport>
-
onClose
public void onClose(io.grpc.Status status, io.grpc.Metadata trailers)- Overrides:
onClosein classio.grpc.ClientCall.Listener<OrcaLoadReport>
-
handleResponse
void handleResponse(OrcaLoadReport response)
-
handleStreamClosed
void handleStreamClosed(io.grpc.Status status)
-
cancel
void cancel(java.lang.String msg)
-
toString
public java.lang.String toString()
- Overrides:
toStringin classjava.lang.Object
-
-