always add, at least, one host per SRV record

luraproject · Dec 12, 2019 · bd41ee2 · bd41ee2
1 parent 928cb98
commit bd41ee2
Showing 1 changed file with 2 additions and 1 deletion.
diff --git a/sd/dnssrv/subscriber.go b/sd/dnssrv/subscriber.go
@@ -85,7 +85,8 @@ func (s subscriber) resolve() ([]string, error) {
 	}
 	instances := []string{}
 	for _, addr := range addrs {
-		for i := 0; i < int(addr.Weight); i++ {
+		instances = append(instances, fmt.Sprintf("http://%s", net.JoinHostPort(addr.Target, fmt.Sprint(addr.Port))))
+		for i := 0; i < int(addr.Weight-1); i++ {
 			instances = append(instances, fmt.Sprintf("http://%s", net.JoinHostPort(addr.Target, fmt.Sprint(addr.Port))))
 		}
 	}