Fix address list collection

slackhq · Nov 2, 2023 · 7b789f5 · 7b789f5
1 parent 144f7e5
commit 7b789f5
Showing 1 changed file with 4 additions and 3 deletions.
diff --git a/go/vt/vtgateproxy/discovery.go b/go/vt/vtgateproxy/discovery.go
@@ -121,8 +121,8 @@ func (r *resolveJSONGateConfig) loadConfig() (*[]resolver.Address, error) {
 
 	fmt.Printf("%v\n", config)
 
-	addrs := make([]resolver.Address, len(config))
-	for i, s := range config {
+	addrs := []resolver.Address{}
+	for _, s := range config {
 		// Apply filters
 		if r.filters.gate_type != "" {
 			if r.filters.gate_type != s.Type {
@@ -138,7 +138,8 @@ func (r *resolveJSONGateConfig) loadConfig() (*[]resolver.Address, error) {
 			}
 		}
 		// Add matching hosts to registration list
-		addrs[i] = resolver.Address{Addr: fmt.Sprintf("%s:%s", s.Address, s.Grpc)}
+		fmt.Printf("selected host for discovery: %v %v\n", fmt.Sprintf("%s:%s", s.Address, s.Grpc), s)
+		addrs = append(addrs, resolver.Address{Addr: fmt.Sprintf("%s:%s", s.Address, s.Grpc)})
 	}
 
 	// Shuffle to ensure every host has a different order to iterate through