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