Package io.grpc.xds.orca
Class OrcaOobUtil.OrcaReportingHelper.OrcaReportingState
- java.lang.Object
-
- io.grpc.xds.orca.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
AnOrcaOobUtil.OrcaReportingHelper.OrcaReportingState
is a client of ORCA service running on a single backend.All methods are run from
syncContext
.
-
-
Nested Class Summary
Nested Classes Modifier and Type Class Description private class
OrcaOobUtil.OrcaReportingHelper.OrcaReportingState.OrcaReportingStream
-
Field Summary
Fields Modifier and Type Field Description private io.grpc.internal.BackoffPolicy
backoffPolicy
private java.util.Map<OrcaOobUtil.OrcaOobReportListener,OrcaOobUtil.OrcaReportingConfig>
configs
private boolean
disabled
private OrcaOobUtil.OrcaReportingHelper.OrcaReportingState.OrcaReportingStream
orcaRpc
private OrcaOobUtil.OrcaReportingConfig
overallConfig
private java.lang.Runnable
retryTask
private io.grpc.SynchronizationContext.ScheduledHandle
retryTimer
private boolean
started
private io.grpc.ConnectivityStateInfo
state
private io.grpc.LoadBalancer.SubchannelStateListener
stateListener
private io.grpc.LoadBalancer.Subchannel
subchannel
private io.grpc.ChannelLogger
subchannelLogger
private io.grpc.SynchronizationContext
syncContext
private java.util.concurrent.ScheduledExecutorService
timeService
-
Constructor Summary
Constructors Constructor Description OrcaReportingState(io.grpc.SynchronizationContext syncContext, java.util.concurrent.ScheduledExecutorService timeService)
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description (package private) void
adjustOrcaReporting()
(package private) void
init(io.grpc.LoadBalancer.Subchannel subchannel, io.grpc.LoadBalancer.SubchannelStateListener stateListener)
(package private) boolean
isRetryTimerPending()
void
onSubchannelState(io.grpc.ConnectivityStateInfo newState)
(package private) void
setListener(OrcaOobUtil.SubchannelImpl orcaSubchannel, OrcaOobUtil.OrcaOobReportListener listener, OrcaOobUtil.OrcaReportingConfig config)
private void
setReportingConfig(OrcaOobUtil.OrcaReportingConfig config)
(package private) void
startRpc()
(package private) void
stopRpc(java.lang.String msg)
java.lang.String
toString()
-
-
-
Field Detail
-
syncContext
private final io.grpc.SynchronizationContext syncContext
-
timeService
private final java.util.concurrent.ScheduledExecutorService timeService
-
configs
private final java.util.Map<OrcaOobUtil.OrcaOobReportListener,OrcaOobUtil.OrcaReportingConfig> configs
-
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
-
orcaRpc
@Nullable private OrcaOobUtil.OrcaReportingHelper.OrcaReportingState.OrcaReportingStream orcaRpc
-
retryTimer
@Nullable private io.grpc.SynchronizationContext.ScheduledHandle retryTimer
-
overallConfig
@Nullable private OrcaOobUtil.OrcaReportingConfig overallConfig
-
retryTask
private final java.lang.Runnable retryTask
-
state
private io.grpc.ConnectivityStateInfo state
-
disabled
private boolean disabled
-
started
private boolean started
-
-
Method Detail
-
init
void init(io.grpc.LoadBalancer.Subchannel subchannel, io.grpc.LoadBalancer.SubchannelStateListener stateListener)
-
setListener
void setListener(OrcaOobUtil.SubchannelImpl orcaSubchannel, OrcaOobUtil.OrcaOobReportListener listener, OrcaOobUtil.OrcaReportingConfig config)
-
setReportingConfig
private void setReportingConfig(OrcaOobUtil.OrcaReportingConfig config)
-
onSubchannelState
public void onSubchannelState(io.grpc.ConnectivityStateInfo newState)
- Specified by:
onSubchannelState
in interfaceio.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 classjava.lang.Object
-
-