millicore.go

package main

import (
	"os/exec"
	"path/filepath"
)

func GetMillicoreConfigTasks(tasks chan<- Task, runner Runner, projects []string, resourceFactory ResourceMatchFactory) {
	for _, p := range projects {
		pods, err := resourceFactory(p, "pod", "millicore")
		if err != nil {
			tasks <- NewError(err)
			continue
		}
		for _, pod := range pods {
			tasks <- GetMillicoreConfig(runner, p, pod)
		}
	}
}

func GetMillicoreConfig(r Runner, project, pod string) Task {
	return func() error {
		cmd := exec.Command("oc", "exec", pod, "--", "cat", "/etc/feedhenry/cluster-override.properties")
		path := filepath.Join("projects", project, "millicore", pod+"_cluster-override.properties")
		return r.Run(cmd, path)
	}
}