Deserialize Kubernetes objects in Go

deserializing-k8s-objects.go

package main

import (
        "fmt"
        "io/ioutil"

        appsv1 "k8s.io/api/apps/v1"
        corev1 "k8s.io/api/core/v1"
        "k8s.io/apimachinery/pkg/runtime"
        "k8s.io/apimachinery/pkg/runtime/serializer"
)

func main() {
        // https://godoc.org/k8s.io/apimachinery/pkg/runtime#Scheme
        scheme := runtime.NewScheme()

        // https://godoc.org/k8s.io/apimachinery/pkg/runtime/serializer#CodecFactory
        codecFactory := serializer.NewCodecFactory(scheme)

        // https://godoc.org/k8s.io/apimachinery/pkg/runtime#Decoder
        deserializer := codecFactory.UniversalDeserializer()

        namespaceYAML, err := ioutil.ReadFile("namespace.yaml")
        if err != nil {
                panic(err)
        }

        namespaceObject, _, err := deserializer.Decode(namespaceYAML, nil, &corev1.Namespace{})
        if err != nil {
                panic(err)
        }
        namespace := namespaceObject.(*corev1.Namespace)
        fmt.Println("==== namespace.yaml ====")
        fmt.Printf("Name: %s\n", namespace.ObjectMeta.GetName())
        fmt.Println()

        deploymentYAML, err := ioutil.ReadFile("deployment.yaml")
        if err != nil {
                panic(err)
        }

        deploymentObject, _, err := deserializer.Decode(deploymentYAML, nil, &appsv1.Deployment{})
        if err != nil {
                panic(err)
        }
        deployment := deploymentObject.(*appsv1.Deployment)
        fmt.Println("==== deployment.yaml ====")
        fmt.Printf("Namespace: %s\n", deployment.ObjectMeta.GetNamespace())
        fmt.Printf("Resources: %+v\n", deployment.Spec.Template.Spec.Containers[0].Resources.Limits["cpu"])
}