Package io.grpc.xds
Class WrrLocalityLoadBalancer
- java.lang.Object
-
- io.grpc.LoadBalancer
-
- io.grpc.xds.WrrLocalityLoadBalancer
-
final class WrrLocalityLoadBalancer extends io.grpc.LoadBalancer
This load balancer acts as a parent for theWeightedTargetLoadBalancer
and configures it with a child policy in its configuration and locality weights it gets from an attribute inLoadBalancer.ResolvedAddresses
.
-
-
Nested Class Summary
Nested Classes Modifier and Type Class Description (package private) static class
WrrLocalityLoadBalancer.WrrLocalityConfig
The LB config forWrrLocalityLoadBalancer
.-
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 io.grpc.LoadBalancer.Helper
helper
private io.grpc.LoadBalancerRegistry
lbRegistry
private XdsLogger
logger
private io.grpc.util.GracefulSwitchLoadBalancer
switchLb
-
Constructor Summary
Constructors Constructor Description WrrLocalityLoadBalancer(io.grpc.LoadBalancer.Helper helper)
WrrLocalityLoadBalancer(io.grpc.LoadBalancer.Helper helper, io.grpc.LoadBalancerRegistry lbRegistry)
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description io.grpc.Status
acceptResolvedAddresses(io.grpc.LoadBalancer.ResolvedAddresses resolvedAddresses)
void
handleNameResolutionError(io.grpc.Status error)
void
shutdown()
-
-
-
Field Detail
-
logger
private final XdsLogger logger
-
helper
private final io.grpc.LoadBalancer.Helper helper
-
switchLb
private final io.grpc.util.GracefulSwitchLoadBalancer switchLb
-
lbRegistry
private final io.grpc.LoadBalancerRegistry lbRegistry
-
-
Method Detail
-
acceptResolvedAddresses
public io.grpc.Status acceptResolvedAddresses(io.grpc.LoadBalancer.ResolvedAddresses resolvedAddresses)
- Overrides:
acceptResolvedAddresses
in classio.grpc.LoadBalancer
-
handleNameResolutionError
public void handleNameResolutionError(io.grpc.Status error)
- Specified by:
handleNameResolutionError
in classio.grpc.LoadBalancer
-
shutdown
public void shutdown()
- Specified by:
shutdown
in classio.grpc.LoadBalancer
-
-