Praefect multiple virtual storage

1 files changed, 15 insertions, 11 deletions

diff --git a/internal/praefect/server.go b/internal/praefect/server.go
index ada0d05f6..46ee62cea 100644
--- a/internal/praefect/server.go
+++ b/internal/praefect/server.go
@@ -37,18 +37,22 @@ type Server struct {
 }
 
 func (srv *Server) warnDupeAddrs(c config.Config) {
-	addrSet := map[string]struct{}{}
-	fishy := false
-	for _, n := range c.Nodes {
-		_, ok := addrSet[n.Address]
-		if ok {
-			srv.l.Warnf("more than one backend node is hosted at %s", n.Address)
-			fishy = true
+	var fishy bool
+
+	for _, virtualStorage := range c.VirtualStorages {
+		addrSet := map[string]struct{}{}
+		for _, n := range virtualStorage.Nodes {
+			_, ok := addrSet[n.Address]
+			if ok {
+				srv.l.Warnf("more than one backend node is hosted at %s", n.Address)
+				fishy = true
+				continue
+			}
+			addrSet[n.Address] = struct{}{}
+		}
+		if fishy {
+			srv.l.Warnf("your Praefect configuration may not offer actual redundancy")
 		}
-		addrSet[n.Address] = struct{}{}
-	}
-	if fishy {
-		srv.l.Warnf("your Praefect configuration may not offer actual redundancy")
 	}
 }