Package io.grpc.xds

Class PriorityLoadBalancer

java.lang.Object

io.grpc.LoadBalancer

io.grpc.xds.PriorityLoadBalancer

final class PriorityLoadBalancer
extends io.grpc.LoadBalancer

Load balancer for priority policy. A priority represents a logical entity within a cluster for load balancing purposes.

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
private final class	PriorityLoadBalancer.ChildLbState

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 final Map<String,PriorityLoadBalancer.ChildLbState>	children
private io.grpc.ConnectivityState	currentConnectivityState
private io.grpc.LoadBalancer.SubchannelPicker	currentPicker
private String	currentPriority
private final ScheduledExecutorService	executor
private boolean	handlingResolvedAddresses
private final io.grpc.LoadBalancer.Helper	helper
private final XdsLogger	logger
private Map<String,PriorityLoadBalancerProvider.PriorityLbConfig.PriorityChildConfig>	priorityConfigs
private List<String>	priorityNames
private io.grpc.LoadBalancer.ResolvedAddresses	resolvedAddresses
private final io.grpc.SynchronizationContext	syncContext

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

Constructor	Description
PriorityLoadBalancer(io.grpc.LoadBalancer.Helper helper)

Method Summary

Modifier and Type	Method	Description
io.grpc.Status	acceptResolvedAddresses(io.grpc.LoadBalancer.ResolvedAddresses resolvedAddresses)
void	handleNameResolutionError(io.grpc.Status error)
void	shutdown()
private void	tryNextPriority()
private void	updateOverallState(String priority, io.grpc.ConnectivityState state, io.grpc.LoadBalancer.SubchannelPicker picker)

Methods inherited from class io.grpc.LoadBalancer

canHandleEmptyAddressListFromNameResolution, handleResolvedAddresses, handleSubchannelState, requestConnection

Methods inherited from class java.lang.Object

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

Field Details

helper

private final io.grpc.LoadBalancer.Helper helper

syncContext

private final io.grpc.SynchronizationContext syncContext

executor

private final ScheduledExecutorService executor

logger

private final XdsLogger logger

children

private final Map<String,PriorityLoadBalancer.ChildLbState> children

resolvedAddresses

private io.grpc.LoadBalancer.ResolvedAddresses resolvedAddresses

priorityNames

private List<String> priorityNames

priorityConfigs

private Map<String,PriorityLoadBalancerProvider.PriorityLbConfig.PriorityChildConfig> priorityConfigs

currentPriority

@Nullable
private String currentPriority

currentConnectivityState

private io.grpc.ConnectivityState currentConnectivityState

currentPicker

private io.grpc.LoadBalancer.SubchannelPicker currentPicker

handlingResolvedAddresses

private boolean handlingResolvedAddresses

Constructor Details

PriorityLoadBalancer

PriorityLoadBalancer(io.grpc.LoadBalancer.Helper helper)

Method Details

acceptResolvedAddresses

public io.grpc.Status acceptResolvedAddresses(io.grpc.LoadBalancer.ResolvedAddresses resolvedAddresses)

Overrides:

acceptResolvedAddresses in class io.grpc.LoadBalancer

handleNameResolutionError

public void handleNameResolutionError(io.grpc.Status error)

Specified by:

handleNameResolutionError in class io.grpc.LoadBalancer

shutdown

public void shutdown()

Specified by:

shutdown in class io.grpc.LoadBalancer

tryNextPriority

private void tryNextPriority()

updateOverallState

private void updateOverallState(@Nullable
 String priority,
 io.grpc.ConnectivityState state,
 io.grpc.LoadBalancer.SubchannelPicker picker)