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
-
Constructor Summary
Constructors Constructor Description WeightedTargetLoadBalancer(io.grpc.LoadBalancer.Helper helper)
-
Method Summary
All Methods Static Methods Instance Methods Concrete Methods 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()
-
-
-
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
-
-
Method Detail
-
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
@Nullable private static io.grpc.ConnectivityState aggregateState(@Nullable io.grpc.ConnectivityState overallState, io.grpc.ConnectivityState childState)
-
-