Package io.grpc.xds
Class RingHashLoadBalancer.RingHashPicker
java.lang.Object
io.grpc.LoadBalancer.SubchannelPicker
io.grpc.xds.RingHashLoadBalancer.RingHashPicker
- Enclosing class:
RingHashLoadBalancer
private static final class RingHashLoadBalancer.RingHashPicker
extends io.grpc.LoadBalancer.SubchannelPicker
-
Field Summary
FieldsModifier and TypeFieldDescriptionprivate final Map
<io.grpc.util.MultiChildLoadBalancer.Endpoint, RingHashLoadBalancer.SubchannelView> private final List
<RingHashLoadBalancer.RingEntry> private final io.grpc.SynchronizationContext
-
Constructor Summary
ConstructorsModifierConstructorDescriptionprivate
RingHashPicker
(io.grpc.SynchronizationContext syncContext, List<RingHashLoadBalancer.RingEntry> ring, Collection<io.grpc.util.MultiChildLoadBalancer.ChildLbState> children) -
Method Summary
Modifier and TypeMethodDescriptionprivate int
getTargetIndex
(Long requestHash) io.grpc.LoadBalancer.PickResult
pickSubchannel
(io.grpc.LoadBalancer.PickSubchannelArgs args) Methods inherited from class io.grpc.LoadBalancer.SubchannelPicker
requestConnection
-
Field Details
-
syncContext
private final io.grpc.SynchronizationContext syncContext -
ring
-
pickableSubchannels
private final Map<io.grpc.util.MultiChildLoadBalancer.Endpoint,RingHashLoadBalancer.SubchannelView> pickableSubchannels
-
-
Constructor Details
-
RingHashPicker
private RingHashPicker(io.grpc.SynchronizationContext syncContext, List<RingHashLoadBalancer.RingEntry> ring, Collection<io.grpc.util.MultiChildLoadBalancer.ChildLbState> children)
-
-
Method Details
-
getTargetIndex
-
pickSubchannel
public io.grpc.LoadBalancer.PickResult pickSubchannel(io.grpc.LoadBalancer.PickSubchannelArgs args) - Specified by:
pickSubchannel
in classio.grpc.LoadBalancer.SubchannelPicker
-