Class HealthCheckingLoadBalancerFactory.HealthCheckState
- All Implemented Interfaces:
LoadBalancer.SubchannelStateListener
- Enclosing class:
HealthCheckingLoadBalancerFactory
-
Nested Class Summary
Nested ClassesModifier and TypeClassDescriptionprivate class
-
Field Summary
FieldsModifier and TypeFieldDescriptionprivate BackoffPolicy
private ConnectivityStateInfo
private boolean
private final HealthCheckingLoadBalancerFactory.HelperImpl
private ConnectivityStateInfo
private final Runnable
private boolean
private String
private LoadBalancer.Subchannel
private ChannelLogger
private final SynchronizationContext
private final ScheduledExecutorService
-
Constructor Summary
ConstructorsConstructorDescriptionHealthCheckState
(HealthCheckingLoadBalancerFactory.HelperImpl helperImpl, SynchronizationContext syncContext, ScheduledExecutorService timerService, LoadBalancer.SubchannelStateListener healthListener) -
Method Summary
Modifier and TypeMethodDescriptionprivate void
private void
gotoState
(ConnectivityStateInfo newState) (package private) void
init
(LoadBalancer.SubchannelStateListener listener) private boolean
void
onSubchannelState
(ConnectivityStateInfo rawState) Handles a state change on a Subchannel.(package private) void
setServiceName
(String newServiceName) (package private) void
setSubchannel
(LoadBalancer.Subchannel subchannel) private void
startRpc()
private void
toString()
-
Field Details
-
retryTask
-
syncContext
-
timerService
-
helperImpl
-
subchannel
-
subchannelLogger
-
stateListener
-
activeRpc
-
serviceName
-
backoffPolicy
-
rawState
-
concludedState
-
running
private boolean running -
disabled
private boolean disabled -
retryTimer
-
-
Constructor Details
-
HealthCheckState
HealthCheckState(HealthCheckingLoadBalancerFactory.HelperImpl helperImpl, SynchronizationContext syncContext, ScheduledExecutorService timerService, @Nullable LoadBalancer.SubchannelStateListener healthListener)
-
-
Method Details
-
setSubchannel
-
init
-
setServiceName
-
onSubchannelState
Description copied from interface:LoadBalancer.SubchannelStateListener
Handles a state change on a Subchannel.The initial state of a Subchannel is IDLE. You won't get a notification for the initial IDLE state.
If the new state is not SHUTDOWN, this method should create a new picker and call
Helper.updateBalancingState()
. Failing to do so may result in unnecessary delays of RPCs. Please refer toPickResult.withSubchannel()
's javadoc for more information.When a subchannel's state is IDLE or TRANSIENT_FAILURE and the address for the subchannel was received in
LoadBalancer.handleResolvedAddresses(io.grpc.LoadBalancer.ResolvedAddresses)
, load balancers should callLoadBalancer.Helper.refreshNameResolution()
to inform polling name resolvers that it is an appropriate time to refresh the addresses. Without the refresh, changes to the addresses may never be detected.SHUTDOWN can only happen in two cases. One is that LoadBalancer called
LoadBalancer.Subchannel.shutdown()
earlier, thus it should have already discarded this Subchannel. The other is that Channel is doing aforced shutdown
or has already terminated, thus there won't be further requests to LoadBalancer. Therefore, the LoadBalancer usually don't need to react to a SHUTDOWN state.- Specified by:
onSubchannelState
in interfaceLoadBalancer.SubchannelStateListener
- Parameters:
rawState
- the new state
-
isRetryTimerPending
private boolean isRetryTimerPending() -
adjustHealthCheck
private void adjustHealthCheck() -
startRpc
private void startRpc() -
stopRpc
-
gotoState
-
toString
-