GetKubeResourceDetailFromYaml.go

package main

import (
	"bufio"
	"bytes"
	"fmt"
	"io"
	"k8s.io/client-go/kubernetes/scheme"
	"os"
	"os/user"
	"regexp"
)

func main() {
	file, err := os.Open(HomeDir("proctor-manifest.yaml"))
	if err != nil {
		fmt.Printf("%#v", err)
	}

	decode := scheme.Codecs.UniversalDeserializer().Decode
	yamlDocs := SplitYaml(file)

	for _, yaml := range yamlDocs {
		obj, groupKind, err := decode([]byte(yaml), nil, nil)
		if err != nil {
			fmt.Printf("%#v", err)
		}
		fmt.Printf("=====================\n")
		fmt.Printf("%#v\n", groupKind)
		fmt.Printf("%#v\n", obj)
	}

}

func HomeDir(children ...string) string {
	usr, _ := user.Current()
	home := usr.HomeDir
	for _, child := range children {
		home = fmt.Sprintf("%s/%s", home, child)
	}

	return home
}

func SplitYaml(source io.ReadCloser) (result []string) {
	separator := regexp.MustCompile("(^-+$)")
	whitespace := regexp.MustCompile(`^\s+$`)
	scanner := bufio.NewScanner(source)

	result = []string{}
	stringBuffer := bytes.NewBufferString("")
	for scanner.Scan() {
		text := scanner.Text()
		if separator.MatchString(text) {
			yamlDoc := stringBuffer.String()
			if !whitespace.MatchString(yamlDoc) {
				result = append(result, stringBuffer.String())
			}
			stringBuffer.Reset()
		} else {
			stringBuffer.WriteString(fmt.Sprintf("%s\n", text))
		}
	}

	yamlDoc := stringBuffer.String()
	if !whitespace.MatchString(yamlDoc) {
		result = append(result, stringBuffer.String())
	}

	stringBuffer.Reset()

	return
}

Support multiple Yaml config in single file, separated to with ---.