Apply extra manifests

Signed-off-by: Kimmo Lehto <klehto@mirantis.com>

action/apply.go

@@ -90,6 +90,7 @@ func NewApply(opts ApplyOptions) *Apply {
 			&phase.ResetWorkers{NoDrain: opts.NoDrain},
 			&phase.ResetControllers{NoDrain: opts.NoDrain},
 			&phase.RunHooks{Stage: "after", Action: "apply"},
+			&phase.ApplyManifests{},
 			unlockPhase,
 			&phase.Disconnect{},
 		},

phase/apply_manifests.go

@@ -0,0 +1,63 @@
+package phase
+
+import (
+	"bytes"
+	"fmt"
+	"io"
+
+	"github.com/k0sproject/k0sctl/pkg/apis/k0sctl.k0sproject.io/v1beta1"
+	"github.com/k0sproject/k0sctl/pkg/apis/k0sctl.k0sproject.io/v1beta1/cluster"
+	log "github.com/sirupsen/logrus"
+)
+
+// ApplyManifests is a phase that applies additional manifests to the cluster
+type ApplyManifests struct {
+	GenericPhase
+	leader *cluster.Host
+}
+
+// Title for the phase
+func (p *ApplyManifests) Title() string {
+	return "Apply additional manifests"
+}
+
+// Prepare the phase
+func (p *ApplyManifests) Prepare(config *v1beta1.Cluster) error {
+	p.Config = config
+	p.leader = p.Config.Spec.K0sLeader()
+
+	return nil
+}
+
+// ShouldRun is true when there are additional manifests to apply
+func (p *ApplyManifests) ShouldRun() bool {
+	return len(p.Config.Metadata.Manifests) > 0
+}
+
+// Run the phase
+func (p *ApplyManifests) Run() error {
+	for name, content := range p.Config.Metadata.Manifests {
+		if err := p.apply(name, content); err != nil {
+			return err
+		}
+	}
+
+	return nil
+}
+
+func (p *ApplyManifests) apply(name string, content []byte) error {
+	kubectlCmd := p.leader.Configurer.KubectlCmdf(p.leader, "apply", "-f", "-")
+	var stdout, stderr bytes.Buffer
+
+	cmd, err := p.leader.ExecStreams(kubectlCmd, io.NopCloser(bytes.NewReader(content)), &stdout, &stderr)
+	if err != nil {
+		return fmt.Errorf("failed to run apply for manifest %s: %w", name, err)
+	}
+	if err := cmd.Wait(); err != nil {
+		log.Errorf("kubectl apply failed for manifest %s", name)
+		log.Errorf("kubectl apply stdout: %s", stdout.String())
+		log.Errorf("kubectl apply stderr: %s", stderr.String())
+		return fmt.Errorf("failed to apply manifest %s: %w", name, err)
+	}
+	return nil
+}