Class RoundRobinLoadBalancer

java.lang.Object

io.grpc.LoadBalancer

io.grpc.util.MultiChildLoadBalancer

io.grpc.util.RoundRobinLoadBalancer

final class RoundRobinLoadBalancer
extends MultiChildLoadBalancer

A LoadBalancer that provides round-robin load-balancing over the EquivalentAddressGroups from the NameResolver.

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
(package private) static class	RoundRobinLoadBalancer.ReadyPicker

Nested classes/interfaces inherited from class MultiChildLoadBalancer

MultiChildLoadBalancer.AcceptResolvedAddrRetVal, MultiChildLoadBalancer.ChildLbState, MultiChildLoadBalancer.Endpoint

Nested classes/interfaces inherited from class LoadBalancer

LoadBalancer.CreateSubchannelArgs, LoadBalancer.ErrorPicker, LoadBalancer.Factory, LoadBalancer.FixedResultPicker, LoadBalancer.Helper, LoadBalancer.PickDetailsConsumer, LoadBalancer.PickResult, LoadBalancer.PickSubchannelArgs, LoadBalancer.ResolvedAddresses, LoadBalancer.Subchannel, LoadBalancer.SubchannelPicker, LoadBalancer.SubchannelStateListener

Field Summary

Fields

Modifier and Type	Field	Description
private LoadBalancer.SubchannelPicker	currentPicker
private final AtomicInteger	sequence

Fields inherited from class MultiChildLoadBalancer

currentConnectivityState, pickFirstLbProvider, resolvingAddresses

Fields inherited from class 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
RoundRobinLoadBalancer(LoadBalancer.Helper helper)

Method Summary

Modifier and Type	Method	Description
protected MultiChildLoadBalancer.ChildLbState	createChildLbState(Object key)	Override to create an instance of a subclass.
private LoadBalancer.SubchannelPicker	createReadyPicker(Collection<MultiChildLoadBalancer.ChildLbState> children)
private void	updateBalancingState(ConnectivityState state, LoadBalancer.SubchannelPicker picker)
protected void	updateOverallBalancingState()	Updates picker with the list of active subchannels (state == READY).

Methods inherited from class MultiChildLoadBalancer

acceptResolvedAddresses, acceptResolvedAddressesInternal, aggregateState, createChildAddressesMap, getChildLbState, getChildLbStateEag, getChildLbStates, getHelper, getReadyChildren, handleNameResolutionError, shutdown, shutdownRemoved

Methods inherited from class LoadBalancer

canHandleEmptyAddressListFromNameResolution, handleResolvedAddresses, handleSubchannelState, requestConnection

Methods inherited from class Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Field Details

sequence

private final AtomicInteger sequence

currentPicker

private LoadBalancer.SubchannelPicker currentPicker

Constructor Details

RoundRobinLoadBalancer

public RoundRobinLoadBalancer(LoadBalancer.Helper helper)

Method Details

updateOverallBalancingState

protected void updateOverallBalancingState()

Updates picker with the list of active subchannels (state == READY).

Specified by:

updateOverallBalancingState in class MultiChildLoadBalancer

updateBalancingState

private void updateBalancingState(ConnectivityState state,
 LoadBalancer.SubchannelPicker picker)

createReadyPicker

private LoadBalancer.SubchannelPicker createReadyPicker(Collection<MultiChildLoadBalancer.ChildLbState> children)

createChildLbState

protected MultiChildLoadBalancer.ChildLbState createChildLbState(Object key)

Description copied from class: MultiChildLoadBalancer

Override to create an instance of a subclass.

Overrides:

createChildLbState in class MultiChildLoadBalancer