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 Details

    • call

      private final io.grpc.ClientCall<OrcaLoadReportRequest,OrcaLoadReport> 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

      public void onMessage(OrcaLoadReport response)
      Overrides:
      onMessage in class io.grpc.ClientCall.Listener<OrcaLoadReport>
    • onClose

      public void onClose(io.grpc.Status status, io.grpc.Metadata trailers)
      Overrides:
      onClose in class io.grpc.ClientCall.Listener<OrcaLoadReport>
    • handleResponse

      void handleResponse(OrcaLoadReport response)
    • handleStreamClosed

      void handleStreamClosed(io.grpc.Status status)
    • cancel

      void cancel(String msg)
    • toString

      public String toString()
      Overrides:
      toString in class Object