Add handling for cri-docker (#540)

* Add handling for cri-docker * add better logging for failures with kubeadm init * fix comment
openconfig · May 28, 2024 · cdcf059 · cdcf059
1 parent 0e17b04
commit cdcf059
Show file tree

Hide file tree

Showing 2 changed files with 34 additions and 2 deletions.
diff --git a/deploy/deploy.go b/deploy/deploy.go
@@ -46,6 +46,7 @@ var (
 	pullRetryDelay  = time.Second
 	poolRetryDelay  = 5 * time.Second
 	healthTimeout   = time.Minute
+	criDocker       = "cri-docker"
 
 	// Stubs for testing.
 	execLookPath       = exec.LookPath
@@ -445,16 +446,35 @@ func (k *KubeadmSpec) Deploy(ctx context.Context) error {
 	args := []string{"kubeadm", "init"}
 	if k.CRISocket != "" {
 		args = append(args, "--cri-socket", k.CRISocket)
+		// If using cri-docker, then ensure the components are running.
+		if strings.Contains(k.CRISocket, criDocker) {
+			if err := run.LogCommand("sudo", "systemctl", "enable", "--now", criDocker+".socket"); err != nil {
+				return err
+			}
+			if err := run.LogCommand("sudo", "systemctl", "enable", "--now", criDocker+".service"); err != nil {
+				return err
+			}
+		}
 	}
 	if k.PodNetworkCIDR != "" {
 		args = append(args, "--pod-network-cidr", k.PodNetworkCIDR)
 	}
 	if k.TokenTTL != "" {
 		args = append(args, "--token-ttl", k.TokenTTL)
 	}
-	if err := run.LogCommand("sudo", args...); err != nil {
-		return err
+	log.Infof("Creating kubeadm cluster with: %v", args)
+	if out, err := run.OutLogCommand("sudo", args...); err != nil {
+		msg := []string{}
+		// Filter output to only show lines relevant to the error message. For kubeadm these are lines
+		// containing "error" in any case.
+		for _, line := range strings.Split(string(out), "\n") {
+			if strings.Contains(strings.ToLower(line), "error") {
+				msg = append(msg, line)
+			}
+		}
+		return fmt.Errorf("%w: %v", err, strings.Join(msg, ", "))
 	}
+	log.Infof("Deployed kubeadm cluster")
 	kubeDir := filepath.Join(homeDir(), ".kube")
 	if err := os.MkdirAll(kubeDir, 0750); err != nil {
 		return err

diff --git a/deploy/deploy_test.go b/deploy/deploy_test.go
@@ -64,6 +64,18 @@ func TestKubeadmSpec(t *testing.T) {
 			{Cmd: "sudo", Args: []string{"cat", "/etc/kubernetes/admin.conf"}},
 			{Cmd: "docker", Args: []string{"network", "create", "kne-kubeadm-.*"}},
 		},
+	}, {
+		desc: "use cri-docker",
+		k: &KubeadmSpec{
+			CRISocket: "unix:///var/run/cri-dockerd.sock",
+		},
+		resp: []fexec.Response{
+			{Cmd: "sudo", Args: []string{"systemctl", "enable", "--now", "cri-docker.socket"}},
+			{Cmd: "sudo", Args: []string{"systemctl", "enable", "--now", "cri-docker.service"}},
+			{Cmd: "sudo", Args: []string{"kubeadm", "init", "--cri-socket", "unix:///var/run/cri-dockerd.sock"}},
+			{Cmd: "sudo", Args: []string{"cat", "/etc/kubernetes/admin.conf"}},
+			{Cmd: "docker", Args: []string{"network", "create", "kne-kubeadm-.*"}},
+		},
 	}, {
 		desc: "allow control plane scheduling",
 		k: &KubeadmSpec{