multi-document-yaml-decoding.go

package main

import (
	"bytes"
	"fmt"
	"io"
	"log"

	"gopkg.in/yaml.v2"
)

// https://github.com/kubernetes/kubernetes/blob/master/hack/testdata/multi-resource-yaml.yaml
const multiYAML = `
apiVersion: v1
kind: Service
metadata:
  name: mock
  labels:
    app: mock
spec:
  ports:
  - port: 99
    protocol: TCP
    targetPort: 9949
  selector:
    app: mock
---
apiVersion: v1
kind: ReplicationController
metadata:
  name: mock
spec:
  replicas: 1
  selector:
    app: mock
  template:
    metadata:
      labels:
        app: mock
    spec:
      containers:
      - name: mock-container
        image: k8s.gcr.io/pause:2.0
        ports:
        - containerPort: 9949
`

func main() {
	b := bytes.NewBufferString(multiYAML)
	dec := yaml.NewDecoder(b)

	// https://github.com/go-yaml/yaml/pull/301/files
	l := []map[interface{}]interface{}{}
	for {
		m := make(map[interface{}]interface{})
		err := dec.Decode(&m)
		if err != nil {
			if err != io.EOF {
				log.Fatal(err)
			} else {
				break
			}
		}
		l = append(l, m)
	}
	fmt.Printf("%v\n", l)
}