From 78bc2849cb945cc72e675a548a000155cf2077b4 Mon Sep 17 00:00:00 2001 From: Jose Diaz-Gonzalez Date: Sat, 20 Jan 2024 05:49:20 -0500 Subject: [PATCH] feat: add longhorn --- plugins/scheduler-k3s/subcommands.go | 17 +++++++++++++++++ 1 file changed, 17 insertions(+) diff --git a/plugins/scheduler-k3s/subcommands.go b/plugins/scheduler-k3s/subcommands.go index 6bc94d701..64c045fce 100644 --- a/plugins/scheduler-k3s/subcommands.go +++ b/plugins/scheduler-k3s/subcommands.go @@ -211,6 +211,23 @@ func CommandInitialize(taintScheduling bool) error { return fmt.Errorf("Invalid exit code from setfacl command: %d", registryAclCmd.ExitCode) } + common.LogInfo2Quiet("Installing longhorn") + longhornCmd, err := common.CallExecCommand(common.ExecCommandInput{ + Command: "kubectl", + Args: []string{ + "apply", + "-f", + "https://raw.githubusercontent.com/longhorn/longhorn/v1.4.0/deploy/longhorn.yaml", + }, + StreamStdio: true, + }) + if err != nil { + return fmt.Errorf("Unable to call kubectl command: %w", err) + } + if longhornCmd.ExitCode != 0 { + return fmt.Errorf("Invalid exit code from kubectl command: %d", longhornCmd.ExitCode) + } + common.LogInfo2Quiet("Installing k3s automatic upgrader") upgradeCmd, err := common.CallExecCommand(common.ExecCommandInput{ Command: "kubectl",