Package io.grpc.xds

Class ClusterImplLoadBalancer

java.lang.Object

io.grpc.LoadBalancer

io.grpc.xds.ClusterImplLoadBalancer

final class ClusterImplLoadBalancer
extends io.grpc.LoadBalancer

Load balancer for cluster_impl_experimental LB policy. This LB policy is the child LB policy of the priority_experimental LB policy and the parent LB policy of the weighted_target_experimental LB policy in the xDS load balancing hierarchy. This LB policy applies cluster-level configurations to requests sent to the corresponding cluster, such as drop policies, circuit breakers.

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
private final class	ClusterImplLoadBalancer.ClusterImplLbHelper	A decorated LoadBalancer.Helper that applies configurations for connections or requests to endpoints in the cluster.
(package private) static final class	ClusterImplLoadBalancer.ClusterLocality	Represents the LoadStatsManager2.ClusterLocalityStats and network locality name of a cluster.
private static final class	ClusterImplLoadBalancer.CountingStreamTracerFactory
private static final class	ClusterImplLoadBalancer.OrcaPerRpcListener

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 static final io.grpc.Attributes.Key<AtomicReference<ClusterImplLoadBalancer.ClusterLocality>>	ATTR_CLUSTER_LOCALITY
private XdsNameResolverProvider.CallCounterProvider	callCounterProvider
private ClusterImplLoadBalancer.ClusterImplLbHelper	childLbHelper
private io.grpc.util.GracefulSwitchLoadBalancer	childSwitchLb
private String	cluster
(package private) static final long	DEFAULT_PER_CLUSTER_MAX_CONCURRENT_REQUESTS
private LoadStatsManager2.ClusterDropStats	dropStats
private String	edsServiceName
(package private) static boolean	enableCircuitBreaking
private final io.grpc.LoadBalancer.Helper	helper
private final XdsLogger	logger
private final ThreadSafeRandom	random
private XdsClient	xdsClient
private io.grpc.internal.ObjectPool<XdsClient>	xdsClientPool

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
ClusterImplLoadBalancer(io.grpc.LoadBalancer.Helper helper)
ClusterImplLoadBalancer(io.grpc.LoadBalancer.Helper helper, ThreadSafeRandom random)

Method Summary

Modifier and Type	Method	Description
io.grpc.Status	acceptResolvedAddresses(io.grpc.LoadBalancer.ResolvedAddresses resolvedAddresses)
void	handleNameResolutionError(io.grpc.Status error)
void	requestConnection()
void	shutdown()

Methods inherited from class io.grpc.LoadBalancer

canHandleEmptyAddressListFromNameResolution, handleResolvedAddresses, handleSubchannelState

Methods inherited from class java.lang.Object

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

Field Details

DEFAULT_PER_CLUSTER_MAX_CONCURRENT_REQUESTS

static final long DEFAULT_PER_CLUSTER_MAX_CONCURRENT_REQUESTS

See Also:

• Constant Field Values

enableCircuitBreaking

static boolean enableCircuitBreaking

ATTR_CLUSTER_LOCALITY

private static final io.grpc.Attributes.Key<AtomicReference<ClusterImplLoadBalancer.ClusterLocality>> ATTR_CLUSTER_LOCALITY

logger

private final XdsLogger logger

helper

private final io.grpc.LoadBalancer.Helper helper

random

private final ThreadSafeRandom random

cluster

private String cluster

edsServiceName

@Nullable
private String edsServiceName

xdsClientPool

private io.grpc.internal.ObjectPool<XdsClient> xdsClientPool

xdsClient

private XdsClient xdsClient

callCounterProvider

private XdsNameResolverProvider.CallCounterProvider callCounterProvider

dropStats

private LoadStatsManager2.ClusterDropStats dropStats

childLbHelper

private ClusterImplLoadBalancer.ClusterImplLbHelper childLbHelper

childSwitchLb

private io.grpc.util.GracefulSwitchLoadBalancer childSwitchLb

Constructor Details

ClusterImplLoadBalancer

ClusterImplLoadBalancer(io.grpc.LoadBalancer.Helper helper)

ClusterImplLoadBalancer

ClusterImplLoadBalancer(io.grpc.LoadBalancer.Helper helper,
 ThreadSafeRandom random)

Method Details

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

requestConnection

public void requestConnection()

Overrides:

requestConnection in class io.grpc.LoadBalancer

shutdown

public void shutdown()

Specified by:

shutdown in class io.grpc.LoadBalancer