Package io.grpc.xds
Class ClusterResolverLoadBalancer.ClusterResolverLbState
java.lang.Object
io.grpc.LoadBalancer
io.grpc.xds.ClusterResolverLoadBalancer.ClusterResolverLbState
- Enclosing class:
ClusterResolverLoadBalancer
private final class ClusterResolverLoadBalancer.ClusterResolverLbState
extends io.grpc.LoadBalancer
The state of a cluster_resolver LB working session. A new instance is created whenever
the cluster_resolver LB receives a new config. The old instance is replaced when the
new one is ready to handle new RPCs.
-
Nested Class Summary
Nested ClassesModifier and TypeClassDescriptionprivate class
Resolution state of an underlying cluster.private final class
private final class
private final class
Wires re-resolution requests from downstream LB policies with DNS resolver.Nested classes/interfaces inherited from class io.grpc.LoadBalancer
io.grpc.LoadBalancer.CreateSubchannelArgs, io.grpc.LoadBalancer.ErrorPicker, io.grpc.LoadBalancer.Factory, io.grpc.LoadBalancer.FixedResultPicker, io.grpc.LoadBalancer.Helper, io.grpc.LoadBalancer.PickDetailsConsumer, io.grpc.LoadBalancer.PickResult, io.grpc.LoadBalancer.PickSubchannelArgs, io.grpc.LoadBalancer.ResolvedAddresses, io.grpc.LoadBalancer.Subchannel, io.grpc.LoadBalancer.SubchannelPicker, io.grpc.LoadBalancer.SubchannelStateListener
-
Field Summary
FieldsModifier and TypeFieldDescriptionprivate io.grpc.LoadBalancer
private Object
private final io.grpc.LoadBalancer.Helper
private io.grpc.LoadBalancer.ResolvedAddresses
Fields inherited from class io.grpc.LoadBalancer
ATTR_HEALTH_CHECKING_CONFIG, DISABLE_SUBCHANNEL_RECONNECT_KEY, EMPTY_PICKER, HAS_HEALTH_PRODUCER_LISTENER_KEY, HEALTH_CONSUMER_LISTENER_ARG_KEY, IS_PETIOLE_POLICY
-
Constructor Summary
Constructors -
Method Summary
Modifier and TypeMethodDescriptionio.grpc.Status
acceptResolvedAddresses
(io.grpc.LoadBalancer.ResolvedAddresses resolvedAddresses) private void
private void
void
handleNameResolutionError
(io.grpc.Status error) void
shutdown()
Methods inherited from class io.grpc.LoadBalancer
canHandleEmptyAddressListFromNameResolution, handleResolvedAddresses, handleSubchannelState, requestConnection
-
Field Details
-
helper
private final io.grpc.LoadBalancer.Helper helper -
clusters
-
clusterStates
private final Map<String,ClusterResolverLoadBalancer.ClusterResolverLbState.ClusterState> clusterStates -
endpointLbConfig
-
resolvedAddresses
private io.grpc.LoadBalancer.ResolvedAddresses resolvedAddresses -
childLb
private io.grpc.LoadBalancer childLb
-
-
Constructor Details
-
ClusterResolverLbState
ClusterResolverLbState(io.grpc.LoadBalancer.Helper helper)
-
-
Method Details
-
acceptResolvedAddresses
public io.grpc.Status acceptResolvedAddresses(io.grpc.LoadBalancer.ResolvedAddresses resolvedAddresses) - Overrides:
acceptResolvedAddresses
in classio.grpc.LoadBalancer
-
handleNameResolutionError
public void handleNameResolutionError(io.grpc.Status error) - Specified by:
handleNameResolutionError
in classio.grpc.LoadBalancer
-
shutdown
public void shutdown()- Specified by:
shutdown
in classio.grpc.LoadBalancer
-
handleEndpointResourceUpdate
private void handleEndpointResourceUpdate() -
handleEndpointResolutionError
private void handleEndpointResolutionError()
-