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

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

Constructor	Description
ClusterResolverLbState(io.grpc.LoadBalancer.Helper helper)

Method Summary

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()

Methods inherited from class io.grpc.LoadBalancer

canHandleEmptyAddressListFromNameResolution, handleResolvedAddresses, handleSubchannelState, requestConnection

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

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

Constructor Detail

ClusterResolverLbState

ClusterResolverLbState(io.grpc.LoadBalancer.Helper helper)

Method Detail

acceptResolvedAddresses

public io.grpc.Status acceptResolvedAddresses(io.grpc.LoadBalancer.ResolvedAddresses resolvedAddresses)

Overrides:

acceptResolvedAddresses in class io.grpc.LoadBalancer

handleNameResolutionError

public void handleNameResolutionError(io.grpc.Status error)

Specified by:

handleNameResolutionError in class io.grpc.LoadBalancer

shutdown

public void shutdown()

Specified by:

shutdown in class io.grpc.LoadBalancer

handleEndpointResourceUpdate

private void handleEndpointResourceUpdate()

handleEndpointResolutionError

private void handleEndpointResolutionError()