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 ClassesNested 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
FieldsModifier and TypeFieldDescriptionstatic final io.grpc.Attributes.Key
<String> private final Map
<String, WeightedTargetLoadBalancer.ChildHelper> private final io.grpc.LoadBalancer.Helper
private final XdsLogger
private boolean
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 -
Method Summary
Modifier and TypeMethodDescriptionio.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
void
handleNameResolutionError
(io.grpc.Status error) void
shutdown()
private void
Methods inherited from class io.grpc.LoadBalancer
handleResolvedAddresses, handleSubchannelState, requestConnection
-
Field Details
-
CHILD_NAME
-
logger
-
childBalancers
-
childHelpers
-
helper
private final io.grpc.LoadBalancer.Helper helper -
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 classio.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 classio.grpc.LoadBalancer
-
canHandleEmptyAddressListFromNameResolution
public boolean canHandleEmptyAddressListFromNameResolution()- Overrides:
canHandleEmptyAddressListFromNameResolution
in classio.grpc.LoadBalancer
-
shutdown
public void shutdown()- Specified by:
shutdown
in classio.grpc.LoadBalancer
-
updateOverallBalancingState
private void updateOverallBalancingState() -
aggregateState
-