Use local numConnections

go/vt/vtgateproxy/discovery.go

@@ -71,12 +71,13 @@ func (r *JSONGateResolver) Close() {
 }
 
 type JSONGateResolverBuilder struct {
-	jsonPath      string
-	addressField  string
-	portField     string
-	poolTypeField string
-	affinityField string
-	affinityValue string
+	jsonPath       string
+	addressField   string
+	portField      string
+	poolTypeField  string
+	affinityField  string
+	affinityValue  string
+	numConnections int
 
 	mu        sync.RWMutex
 	targets   map[string][]targetHost
@@ -105,15 +106,17 @@ func RegisterJSONGateResolver(
 	poolTypeField string,
 	affinityField string,
 	affinityValue string,
+	numConnections int,
 ) (*JSONGateResolverBuilder, error) {
 	jsonDiscovery := &JSONGateResolverBuilder{
-		targets:       map[string][]targetHost{},
-		jsonPath:      jsonPath,
-		addressField:  addressField,
-		portField:     portField,
-		poolTypeField: poolTypeField,
-		affinityField: affinityField,
-		affinityValue: affinityValue,
+		targets:        map[string][]targetHost{},
+		jsonPath:       jsonPath,
+		addressField:   addressField,
+		portField:      portField,
+		poolTypeField:  poolTypeField,
+		affinityField:  affinityField,
+		affinityValue:  affinityValue,
+		numConnections: numConnections,
 	}
 
 	resolver.Register(jsonDiscovery)
@@ -293,8 +296,8 @@ func (b *JSONGateResolverBuilder) parse() (bool, error) {
 				return b.affinityValue == targets[poolType][i].Affinity
 			})
 		}
-		if len(targets[poolType]) > *numConnections {
-			targets[poolType] = targets[poolType][:*numConnections]
+		if len(targets[poolType]) > b.numConnections {
+			targets[poolType] = targets[poolType][:b.numConnections]
 		}
 		targetCount.Set(poolType, int64(len(targets[poolType])))
 	}

go/vt/vtgateproxy/vtgateproxy.go

@@ -213,5 +213,6 @@ func Init() {
 		*poolTypeField,
 		*affinityField,
 		*affinityValue,
+		*numConnections,
 	)
 }