Lines Matching defs:edsBalancerImpl
69 type edsBalancerImpl struct { struct
70 cc balancer.ClientConn
71 buildOpts balancer.BuildOptions
72 logger *grpclog.PrefixLogger
73 loadReporter load.PerClusterReporter
75 enqueueChildBalancerStateUpdate func(priorityType, balancer.State)
77 subBalancerBuilder balancer.Builder
78 priorityToLocalities map[priorityType]*balancerGroupWithConfig
79 respReceived bool
86 priorityMu sync.Mutex
88 priorityInUse priorityType
89 priorityLowest priorityType
90 priorityToState map[priorityType]*balancer.State
96 priorityInitTimer *time.Timer
98 subConnMu sync.Mutex
99 subConnToPriority map[balancer.SubConn]priorityType
101 pickerMu sync.Mutex
102 dropConfig []xdsclient.OverloadDropConfig
103 drops []*dropper
104 innerState balancer.State // The state of the picker without drop support.
105 serviceRequestsCounter *client.ServiceRequestsCounter
106 serviceRequestCountMax uint32
108 clusterNameMu sync.Mutex
109 clusterName string
140 func (edsImpl *edsBalancerImpl) handleChildPolicy(name string, config json.RawMessage) {
176 func (edsImpl *edsBalancerImpl) updateDrops(dropConfig []xdsclient.OverloadDropConfig) {
201 func (edsImpl *edsBalancerImpl) handleEDSResponse(edsResp xdsclient.EndpointsUpdate) {
293 …) handleEDSResponsePerPriority(bgwc *balancerGroupWithConfig, newLocalities []xdsclient.Locality) {
400 …nc (edsImpl *edsBalancerImpl) handleSubConnStateChange(sc balancer.SubConn, s connectivity.State) {
421 func (edsImpl *edsBalancerImpl) updateServiceRequestsConfig(serviceName string, max *uint32) {
450 func (edsImpl *edsBalancerImpl) updateClusterName(name string) {
456 func (edsImpl *edsBalancerImpl) getClusterName() string {
464 func (edsImpl *edsBalancerImpl) updateState(priority priorityType, s balancer.State) {
480 func (edsImpl *edsBalancerImpl) ccWrapperWithPriority(priority priorityType) *edsBalancerWrapperCC {
518 …riorityType, addrs []resolver.Address, opts balancer.NewSubConnOptions) (balancer.SubConn, error) {
530 func (edsImpl *edsBalancerImpl) close() {