Class WeightedRoundRobinLoadBalancer.WeightedChildLbState

java.lang.Object

io.grpc.util.MultiChildLoadBalancer.ChildLbState

io.grpc.xds.WeightedRoundRobinLoadBalancer.WeightedChildLbState

Enclosing class:

WeightedRoundRobinLoadBalancer

final class WeightedRoundRobinLoadBalancer.WeightedChildLbState
extends io.grpc.util.MultiChildLoadBalancer.ChildLbState

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
(package private) final class	WeightedRoundRobinLoadBalancer.WeightedChildLbState.OrcaReportListener
(package private) final class	WeightedRoundRobinLoadBalancer.WeightedChildLbState.WrrChildLbStateHelper

Nested classes/interfaces inherited from class io.grpc.util.MultiChildLoadBalancer.ChildLbState

io.grpc.util.MultiChildLoadBalancer.ChildLbState.ChildLbStateHelper

Field Summary

Fields

Modifier and Type	Field	Description
private long	lastUpdated
private long	nonEmptySince
private WeightedRoundRobinLoadBalancer.WeightedChildLbState.OrcaReportListener	orcaReportListener
private final Set<WeightedRoundRobinLoadBalancer.WrrSubchannel>	subchannels
private double	weight

Constructor Summary

Constructors

Constructor	Description
WeightedChildLbState(Object key, io.grpc.LoadBalancerProvider policyProvider)

Method Summary

Modifier and Type	Method	Description
void	addSubchannel(WeightedRoundRobinLoadBalancer.WrrSubchannel wrrSubchannel)
protected io.grpc.util.MultiChildLoadBalancer.ChildLbState.ChildLbStateHelper	createChildHelper()
WeightedRoundRobinLoadBalancer.WeightedChildLbState.OrcaReportListener	getOrCreateOrcaListener(float errorUtilizationPenalty)
private double	getWeight(AtomicInteger staleEndpoints, AtomicInteger notYetUsableEndpoints)
void	removeSubchannel(WeightedRoundRobinLoadBalancer.WrrSubchannel wrrSubchannel)

Methods inherited from class io.grpc.util.MultiChildLoadBalancer.ChildLbState

getCurrentPicker, getCurrentState, getEag, getKey, getLb, getResolvedAddresses, setCurrentPicker, setCurrentState, setResolvedAddresses, shutdown, toString

Methods inherited from class Object

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

Field Details

subchannels

private final Set<WeightedRoundRobinLoadBalancer.WrrSubchannel> subchannels

lastUpdated

private volatile long lastUpdated

nonEmptySince

private volatile long nonEmptySince

weight

private volatile double weight

orcaReportListener

private WeightedRoundRobinLoadBalancer.WeightedChildLbState.OrcaReportListener orcaReportListener

Constructor Details

WeightedChildLbState

public WeightedChildLbState(Object key,
 io.grpc.LoadBalancerProvider policyProvider)

Method Details

createChildHelper

protected io.grpc.util.MultiChildLoadBalancer.ChildLbState.ChildLbStateHelper createChildHelper()

Overrides:

createChildHelper in class io.grpc.util.MultiChildLoadBalancer.ChildLbState

getWeight

private double getWeight(AtomicInteger staleEndpoints,
 AtomicInteger notYetUsableEndpoints)

addSubchannel

public void addSubchannel(WeightedRoundRobinLoadBalancer.WrrSubchannel wrrSubchannel)

getOrCreateOrcaListener

public WeightedRoundRobinLoadBalancer.WeightedChildLbState.OrcaReportListener getOrCreateOrcaListener(float errorUtilizationPenalty)

removeSubchannel

public void removeSubchannel(WeightedRoundRobinLoadBalancer.WrrSubchannel wrrSubchannel)