Function ParsePodSpec

etl/podspec.go:40–52

(errCtx *cmn.ETLErrorContext, spec []byte)

}

func ParsePodSpec(errCtx *cmn.ETLErrorContext, spec []byte) (*corev1.Pod, error) {
	obj, _, err := scheme.Codecs.UniversalDeserializer().Decode(spec, nil, nil)
	if err != nil {
		return nil, cmn.NewErrETL(errCtx, "failed to parse pod spec: %v", err)
	}

	pod, ok := obj.(*corev1.Pod)
	if !ok {
		kind := obj.GetObjectKind().GroupVersionKind().Kind
		return nil, cmn.NewErrETL(errCtx, "expected pod spec, got: %s", kind)
	}
	return pod, nil
}

func (b *etlBootstraper) preparePodSpec() (err error) {
	// Override the name (add target's daemon ID and node ID to its name).