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>
call
private boolean
callHasResponded
private com.google.common.base.Stopwatch
stopwatch
-
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) void
cancel(java.lang.String msg)
(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()
java.lang.String
toString()
-
-
-
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:
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
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:
toString
in classjava.lang.Object
-
-