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
137 func (edsImpl *edsBalancerImpl) handleChildPolicy(name string, config json.RawMessage) {
173 func (edsImpl *edsBalancerImpl) updateDrops(dropConfig []xdsclient.OverloadDropConfig) {
198 func (edsImpl *edsBalancerImpl) handleEDSResponse(edsResp xdsclient.EndpointsUpdate) {
290 …) handleEDSResponsePerPriority(bgwc *balancerGroupWithConfig, newLocalities []xdsclient.Locality) {
397 …nc (edsImpl *edsBalancerImpl) handleSubConnStateChange(sc balancer.SubConn, s connectivity.State) {
418 func (edsImpl *edsBalancerImpl) updateServiceRequestsConfig(serviceName string, max *uint32) {
449 func (edsImpl *edsBalancerImpl) updateState(priority priorityType, s balancer.State) {
465 func (edsImpl *edsBalancerImpl) ccWrapperWithPriority(priority priorityType) *edsBalancerWrapperCC {
488 …riorityType, addrs []resolver.Address, opts balancer.NewSubConnOptions) (balancer.SubConn, error) {
500 func (edsImpl *edsBalancerImpl) close() {