Lines Matching defs:edsBalancerImpl

59 type edsBalancerImpl struct {  struct
60 	cc balancer.ClientConn
62 	subBalancerBuilder   balancer.Builder
63 	loadStore            lrs.Store
64 	priorityToLocalities map[priorityType]*balancerGroupWithConfig
71 	priorityMu sync.Mutex
73 	priorityInUse   priorityType
74 	priorityLowest  priorityType
75 	priorityToState map[priorityType]*balancer.State
81 	priorityInitTimer *time.Timer
83 	subConnMu         sync.Mutex
84 	subConnToPriority map[balancer.SubConn]priorityType
86 	pickerMu   sync.Mutex
87 	drops      []*dropper
88 	innerState balancer.State // The state of the picker without drop support.
114 func (edsImpl *edsBalancerImpl) HandleChildPolicy(name string, config json.RawMessage) {
141 func (edsImpl *edsBalancerImpl) updateDrops(dropPolicies []xdsclient.OverloadDropConfig) {
184 func (edsImpl *edsBalancerImpl) HandleEDSResponse(edsResp *xdsclient.EDSUpdate) {
262 …) handleEDSResponsePerPriority(bgwc *balancerGroupWithConfig, newLocalities []xdsclient.Locality) {
338 …nc (edsImpl *edsBalancerImpl) HandleSubConnStateChange(sc balancer.SubConn, s connectivity.State) {
360 func (edsImpl *edsBalancerImpl) updateState(priority priorityType, s balancer.State) {
376 func (edsImpl *edsBalancerImpl) ccWrapperWithPriority(priority priorityType) *edsBalancerWrapperCC {
402 …riorityType, addrs []resolver.Address, opts balancer.NewSubConnOptions) (balancer.SubConn, error) {
414 func (edsImpl *edsBalancerImpl) Close() {