Package io.grpc.xds

Class WeightedTargetLoadBalancer

java.lang.Object

io.grpc.LoadBalancer

io.grpc.xds.WeightedTargetLoadBalancer

final class WeightedTargetLoadBalancer
extends io.grpc.LoadBalancer

Load balancer for weighted_target policy.

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
private final class	WeightedTargetLoadBalancer.ChildHelper

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
static final io.grpc.Attributes.Key<String>	CHILD_NAME
private final Map<String,io.grpc.util.GracefulSwitchLoadBalancer>	childBalancers
private final Map<String,WeightedTargetLoadBalancer.ChildHelper>	childHelpers
private final io.grpc.LoadBalancer.Helper	helper
private final XdsLogger	logger
private boolean	resolvingAddresses
private Map<String,WeightedTargetLoadBalancerProvider.WeightedPolicySelection>	targets

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
WeightedTargetLoadBalancer(io.grpc.LoadBalancer.Helper helper)

Method Summary

Modifier and Type	Method	Description
io.grpc.Status	acceptResolvedAddresses(io.grpc.LoadBalancer.ResolvedAddresses resolvedAddresses)
io.grpc.Status	acceptResolvedAddressesInternal(io.grpc.LoadBalancer.ResolvedAddresses resolvedAddresses)
private static io.grpc.ConnectivityState	aggregateState(io.grpc.ConnectivityState overallState, io.grpc.ConnectivityState childState)
boolean	canHandleEmptyAddressListFromNameResolution()
void	handleNameResolutionError(io.grpc.Status error)
void	shutdown()
private void	updateOverallBalancingState()

Methods inherited from class io.grpc.LoadBalancer

handleResolvedAddresses, handleSubchannelState, requestConnection

Methods inherited from class java.lang.Object

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

Field Details

CHILD_NAME

public static final io.grpc.Attributes.Key<String> CHILD_NAME

logger

private final XdsLogger logger

childBalancers

private final Map<String,io.grpc.util.GracefulSwitchLoadBalancer> childBalancers

childHelpers

private final Map<String,WeightedTargetLoadBalancer.ChildHelper> childHelpers

helper

private final io.grpc.LoadBalancer.Helper helper

targets

private Map<String,WeightedTargetLoadBalancerProvider.WeightedPolicySelection> targets

resolvingAddresses

private boolean resolvingAddresses

Constructor Details

WeightedTargetLoadBalancer

WeightedTargetLoadBalancer(io.grpc.LoadBalancer.Helper helper)

Method Details

acceptResolvedAddresses

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

Overrides:

acceptResolvedAddresses in class io.grpc.LoadBalancer

acceptResolvedAddressesInternal

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

handleNameResolutionError

public void handleNameResolutionError(io.grpc.Status error)

Specified by:

handleNameResolutionError in class io.grpc.LoadBalancer

canHandleEmptyAddressListFromNameResolution

public boolean canHandleEmptyAddressListFromNameResolution()

Overrides:

canHandleEmptyAddressListFromNameResolution in class io.grpc.LoadBalancer

shutdown

public void shutdown()

Specified by:

shutdown in class io.grpc.LoadBalancer

updateOverallBalancingState

private void updateOverallBalancingState()

aggregateState

@Nullable
private static io.grpc.ConnectivityState aggregateState(@Nullable
 io.grpc.ConnectivityState overallState,
 io.grpc.ConnectivityState childState)