Merge pull request #1132 from threefoldtech/development-support-deplo…

…ying-k8s-cluster-on-multible-nodes

deploy k8s workers on multible nodes

grid-cli/cmd/deploy_kubernetes.go

@@ -200,14 +200,18 @@ var deployKubernetesCmd = &cobra.Command{
 				disks,
 				nil,
 				rootfss,
+				uint64(len(workers)),
 			)
 			if err != nil {
 				log.Fatal().Err(err).Send()
 			}
-			workersNode = uint32(workersNodes[0].NodeID)
-		}
-		for i := 0; i < workerNumber; i++ {
-			workers[i].Node = workersNode
+			for i, node := range workersNodes {
+				workers[i].Node = uint32(node.NodeID)
+			}
+		} else {
+			for i := 0; i < workerNumber; i++ {
+				workers[i].Node = workersNode
+			}
 		}
 		cluster, err := command.DeployKubernetesCluster(cmd.Context(), t, master, workers, string(sshKey))
 		if err != nil {
@@ -291,5 +295,4 @@ func init() {
 	deployKubernetesCmd.Flags().Bool("ipv6", false, "assign public ipv6 for master")
 	deployKubernetesCmd.Flags().Bool("ygg", true, "assign yggdrasil ip for master")
 	deployKubernetesCmd.Flags().Bool("mycelium", true, "assign mycelium ip for master")
-
 }

grid-cli/internal/cmd/deploy.go

@@ -5,6 +5,7 @@ import (
 	"context"
 	"fmt"
 	"net"
+	"slices"
 
 	"github.com/pkg/errors"
 	"github.com/rs/zerolog/log"
@@ -57,9 +58,12 @@ func DeployKubernetesCluster(ctx context.Context, t deployer.TFPluginClient, mas
 	networkName := fmt.Sprintf("%snetwork", master.Name)
 	projectName := fmt.Sprintf("kubernetes/%s", master.Name)
 	networkNodes := []uint32{master.Node}
-	if len(workers) > 0 && workers[0].Node != master.Node {
-		networkNodes = append(networkNodes, workers[0].Node)
+	for _, worker := range workers {
+		if !slices.Contains(networkNodes, worker.Node) {
+			networkNodes = append(networkNodes, worker.Node)
+		}
 	}
+
 	network, err := buildNetwork(networkName, projectName, networkNodes, len(master.MyceliumIPSeed) != 0)
 	if err != nil {
 		return workloads.K8sCluster{}, err