Class OrcaOobUtil.OrcaReportingHelper.OrcaReportingState

  • All Implemented Interfaces:
    io.grpc.LoadBalancer.SubchannelStateListener
    Enclosing class:
    OrcaOobUtil.OrcaReportingHelper

    private final class OrcaOobUtil.OrcaReportingHelper.OrcaReportingState
    extends java.lang.Object
    implements io.grpc.LoadBalancer.SubchannelStateListener
    An OrcaOobUtil.OrcaReportingHelper.OrcaReportingState is a client of ORCA service running on a single backend.

    All methods are run from syncContext.

    • Field Detail

      • syncContext

        private final io.grpc.SynchronizationContext syncContext
      • timeService

        private final java.util.concurrent.ScheduledExecutorService timeService
      • subchannel

        @Nullable
        private io.grpc.LoadBalancer.Subchannel subchannel
      • subchannelLogger

        @Nullable
        private io.grpc.ChannelLogger subchannelLogger
      • stateListener

        @Nullable
        private io.grpc.LoadBalancer.SubchannelStateListener stateListener
      • backoffPolicy

        @Nullable
        private io.grpc.internal.BackoffPolicy backoffPolicy
      • retryTimer

        @Nullable
        private io.grpc.SynchronizationContext.ScheduledHandle retryTimer
      • retryTask

        private final java.lang.Runnable retryTask
      • state

        private io.grpc.ConnectivityStateInfo state
      • disabled

        private boolean disabled
      • started

        private boolean started
    • Constructor Detail

      • OrcaReportingState

        OrcaReportingState​(io.grpc.SynchronizationContext syncContext,
                           java.util.concurrent.ScheduledExecutorService timeService)
    • Method Detail

      • init

        void init​(io.grpc.LoadBalancer.Subchannel subchannel,
                  io.grpc.LoadBalancer.SubchannelStateListener stateListener)
      • onSubchannelState

        public void onSubchannelState​(io.grpc.ConnectivityStateInfo newState)
        Specified by:
        onSubchannelState in interface io.grpc.LoadBalancer.SubchannelStateListener
      • adjustOrcaReporting

        void adjustOrcaReporting()
      • startRpc

        void startRpc()
      • stopRpc

        void stopRpc​(java.lang.String msg)
      • isRetryTimerPending

        boolean isRetryTimerPending()
      • toString

        public java.lang.String toString()
        Overrides:
        toString in class java.lang.Object