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 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 io.grpc.Attributes.Key<java.lang.String>	CHILD_NAME
private java.util.Map<java.lang.String,io.grpc.util.GracefulSwitchLoadBalancer>	childBalancers
private java.util.Map<java.lang.String,WeightedTargetLoadBalancer.ChildHelper>	childHelpers
private io.grpc.LoadBalancer.Helper	helper
private XdsLogger	logger
private boolean	resolvingAddresses
private java.util.Map<java.lang.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 Detail

CHILD_NAME

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

logger

private final XdsLogger logger

childBalancers

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

childHelpers

private final java.util.Map<java.lang.String,WeightedTargetLoadBalancer.ChildHelper> childHelpers

helper

private final io.grpc.LoadBalancer.Helper helper

targets

private java.util.Map<java.lang.String,WeightedTargetLoadBalancerProvider.WeightedPolicySelection> targets

resolvingAddresses

private boolean resolvingAddresses

Constructor Detail

WeightedTargetLoadBalancer

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

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)