Lines Matching defs:edsBalancerImpl

62 type edsBalancerImpl struct {  struct
63 	cc     balancer.ClientConn
64 	logger *grpclog.PrefixLogger
66 	enqueueChildBalancerStateUpdate func(priorityType, balancer.State)
68 	subBalancerBuilder   balancer.Builder
69 	loadStore            lrs.Store
70 	priorityToLocalities map[priorityType]*balancerGroupWithConfig
71 	respReceived         bool
78 	priorityMu sync.Mutex
80 	priorityInUse   priorityType
81 	priorityLowest  priorityType
82 	priorityToState map[priorityType]*balancer.State
88 	priorityInitTimer *time.Timer
90 	subConnMu         sync.Mutex
91 	subConnToPriority map[balancer.SubConn]priorityType
93 	pickerMu   sync.Mutex
94 	dropConfig []xdsclient.OverloadDropConfig
95 	drops      []*dropper
96 	innerState balancer.State // The state of the picker without drop support.
125 func (edsImpl *edsBalancerImpl) handleChildPolicy(name string, config json.RawMessage) {
154 func (edsImpl *edsBalancerImpl) updateDrops(dropConfig []xdsclient.OverloadDropConfig) {
179 func (edsImpl *edsBalancerImpl) handleEDSResponse(edsResp xdsclient.EndpointsUpdate) {
268 …) handleEDSResponsePerPriority(bgwc *balancerGroupWithConfig, newLocalities []xdsclient.Locality) {
356 …nc (edsImpl *edsBalancerImpl) handleSubConnStateChange(sc balancer.SubConn, s connectivity.State) {
378 func (edsImpl *edsBalancerImpl) updateState(priority priorityType, s balancer.State) {
394 func (edsImpl *edsBalancerImpl) ccWrapperWithPriority(priority priorityType) *edsBalancerWrapperCC {
417 …riorityType, addrs []resolver.Address, opts balancer.NewSubConnOptions) (balancer.SubConn, error) {
429 func (edsImpl *edsBalancerImpl) close() {