unstructured-decode.go

var decUnstructured = yaml.NewDecodingSerializer(unstructured.UnstructuredJSONScheme)

func DecodePodSpec(spec corev1.PodSpec) (*unstructured.Unstructured, error) {
	pod := &corev1.Pod{
		ObjectMeta: v1.ObjectMeta{
			Name:      "name",
			Namespace: "namespace",
		},
		Spec: *spec.DeepCopy(),
	}

	scheme := runtime.NewScheme()
	corev1.AddToScheme(scheme)
	codec := serializer.NewCodecFactory(scheme).LegacyCodec(corev1.SchemeGroupVersion)

	bytes, err := runtime.Encode(codec, pod)
	if err != nil {
		return nil, err
	}

	resource := &unstructured.Unstructured{}
	_, _, err = decUnstructured.Decode(bytes, nil, resource)
	if err != nil {
		return nil, err
	}

	return resource, nil
}