func connCheckCmdRun()

in cmd/check-apiserver-connectivity.go [29:67]
26 lines of code
6 McCabe index (conditional complexity)

func connCheckCmdRun(cmd *cobra.Command, args []string) error {
	cred, err := utils.GetCredentials()
	if err != nil {
		return fmt.Errorf("failed to authenticate: %w", err)
	}

	vm, err := utils.VirtualMachineScaleSetVMFromConfig()
	if err != nil {
		return fmt.Errorf("getting vm: %w", err)
	}

	// Check connectivity by executing "kubectl version" on the node. This
	// command will try to contact the API server to get the Kubernetes version
	// it is running. Use only the return value of the command, tough.
	command := "kubectl --kubeconfig /var/lib/kubelet/kubeconfig version > /dev/null; echo -n $?"
	res, err := utils.RunCommand(cmd.Context(), cred, vm, &command, commonFlags.Verbose, nil, utils.OutputTruncateTail)
	if err != nil {
		return fmt.Errorf("failed to run command that checks connectivity: %w", err)
	}

	// The stdout should contain the returned value of "kubectl version":
	// 0 (succeeded), otherwise (failure)
	ret, err := strconv.Atoi(res.Stdout)
	if err != nil {
		return fmt.Errorf("couldn't parse stdout of response message:\n%s", res.Stdout)
	}
	if ret != 0 {
		fmt.Printf("Connectivity check: failed with returned value %d: %s\n",
			ret, res.Stderr)

		// Force the binary to return an exit code != 0 (forwarding command's
		// return value). Useful if it is used in scripts.
		os.Exit(ret)
	}

	fmt.Println("Connectivity check: succeeded")

	return nil
}