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 Classes Modifier and Type Class Description private class
ClusterResolverLoadBalancer.ClusterResolverLbState.ClusterState
Resolution state of an underlying cluster.private class
ClusterResolverLoadBalancer.ClusterResolverLbState.EdsClusterState
private class
ClusterResolverLoadBalancer.ClusterResolverLbState.LogicalDnsClusterState
private class
ClusterResolverLoadBalancer.ClusterResolverLbState.RefreshableHelper
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
Fields Modifier and Type Field Description private io.grpc.LoadBalancer
childLb
private java.util.List<java.lang.String>
clusters
private java.util.Map<java.lang.String,ClusterResolverLoadBalancer.ClusterResolverLbState.ClusterState>
clusterStates
private java.lang.Object
endpointLbConfig
private io.grpc.LoadBalancer.Helper
helper
private io.grpc.LoadBalancer.ResolvedAddresses
resolvedAddresses
-
Constructor Summary
Constructors Constructor Description ClusterResolverLbState(io.grpc.LoadBalancer.Helper helper)
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description io.grpc.Status
acceptResolvedAddresses(io.grpc.LoadBalancer.ResolvedAddresses resolvedAddresses)
private void
handleEndpointResolutionError()
private void
handleEndpointResourceUpdate()
void
handleNameResolutionError(io.grpc.Status error)
void
shutdown()
-
-
-
Field Detail
-
helper
private final io.grpc.LoadBalancer.Helper helper
-
clusters
private final java.util.List<java.lang.String> clusters
-
clusterStates
private final java.util.Map<java.lang.String,ClusterResolverLoadBalancer.ClusterResolverLbState.ClusterState> clusterStates
-
endpointLbConfig
private java.lang.Object endpointLbConfig
-
resolvedAddresses
private io.grpc.LoadBalancer.ResolvedAddresses resolvedAddresses
-
childLb
private io.grpc.LoadBalancer childLb
-
-
Method Detail
-
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()
-
-