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 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
.
-
Nested Class Summary
Nested ClassesModifier and TypeClassDescriptionprivate class
-
Field Summary
FieldsModifier and TypeFieldDescriptionprivate io.grpc.internal.BackoffPolicy
private final Map
<OrcaOobUtil.OrcaOobReportListener, OrcaOobUtil.OrcaReportingConfig> private boolean
private OrcaOobUtil.OrcaReportingConfig
private final Runnable
private io.grpc.SynchronizationContext.ScheduledHandle
private boolean
private io.grpc.ConnectivityStateInfo
private io.grpc.LoadBalancer.SubchannelStateListener
private io.grpc.LoadBalancer.Subchannel
private io.grpc.ChannelLogger
private final io.grpc.SynchronizationContext
private final ScheduledExecutorService
-
Constructor Summary
ConstructorsConstructorDescriptionOrcaReportingState
(io.grpc.SynchronizationContext syncContext, ScheduledExecutorService timeService) -
Method Summary
Modifier and TypeMethodDescription(package private) void
(package private) void
init
(io.grpc.LoadBalancer.Subchannel subchannel, io.grpc.LoadBalancer.SubchannelStateListener stateListener) (package private) boolean
void
onSubchannelState
(io.grpc.ConnectivityStateInfo newState) (package private) void
setListener
(OrcaOobUtil.SubchannelImpl orcaSubchannel, OrcaOobUtil.OrcaOobReportListener listener, OrcaOobUtil.OrcaReportingConfig config) private void
(package private) void
startRpc()
(package private) void
toString()
-
Field Details
-
syncContext
private final io.grpc.SynchronizationContext syncContext -
timeService
-
configs
-
subchannel
-
subchannelLogger
-
stateListener
-
backoffPolicy
-
orcaRpc
-
retryTimer
-
overallConfig
-
retryTask
-
state
private io.grpc.ConnectivityStateInfo state -
disabled
private boolean disabled -
started
private boolean started
-
-
Constructor Details
-
OrcaReportingState
OrcaReportingState(io.grpc.SynchronizationContext syncContext, ScheduledExecutorService timeService)
-
-
Method Details
-
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
-
onSubchannelState
public void onSubchannelState(io.grpc.ConnectivityStateInfo newState) - Specified by:
onSubchannelState
in interfaceio.grpc.LoadBalancer.SubchannelStateListener
-
adjustOrcaReporting
void adjustOrcaReporting() -
startRpc
void startRpc() -
stopRpc
-
isRetryTimerPending
boolean isRetryTimerPending() -
toString
-