Class OutlierDetectionLoadBalancer.OutlierDetectionSubchannel.OutlierDetectionSubchannelStateListener
- java.lang.Object
-
- io.grpc.util.OutlierDetectionLoadBalancer.OutlierDetectionSubchannel.OutlierDetectionSubchannelStateListener
-
- All Implemented Interfaces:
LoadBalancer.SubchannelStateListener
- Enclosing class:
- OutlierDetectionLoadBalancer.OutlierDetectionSubchannel
class OutlierDetectionLoadBalancer.OutlierDetectionSubchannel.OutlierDetectionSubchannelStateListener extends java.lang.Object implements LoadBalancer.SubchannelStateListener
Wraps the actual listener so that state changes from the actual one can be intercepted.
-
-
Field Summary
Fields Modifier and Type Field Description private LoadBalancer.SubchannelStateListener
delegate
-
Constructor Summary
Constructors Constructor Description OutlierDetectionSubchannelStateListener(LoadBalancer.SubchannelStateListener delegate)
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description void
onSubchannelState(ConnectivityStateInfo newState)
Handles a state change on a Subchannel.
-
-
-
Field Detail
-
delegate
private final LoadBalancer.SubchannelStateListener delegate
-
-
Constructor Detail
-
OutlierDetectionSubchannelStateListener
OutlierDetectionSubchannelStateListener(LoadBalancer.SubchannelStateListener delegate)
-
-
Method Detail
-
onSubchannelState
public void onSubchannelState(ConnectivityStateInfo newState)
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:
newState
- the new state
-
-