Function NewPod

pkg/entity/pod.go:29–64

NewPod creates a Entity for a corresponding *kube.Pod. Pod must be valid.

(kubePod *kube.Pod, defaults kube.ObjectMeta, source string, objects ...deploy.KubeObject)

// NewPod creates a Entity for a corresponding *kube.Pod. Pod must be valid.
func NewPod(kubePod *kube.Pod, defaults kube.ObjectMeta, source string, objects ...deploy.KubeObject) (*Pod, error) {
	if kubePod == nil {
		return nil, fmt.Errorf("cannot create Pod from nil `%s`", source)
	}

	// deep copy
	kubePod, err := copyPod(kubePod)
	if err != nil {
		return nil, err
	}

	base, err := newBase(EntityPod, defaults, source, objects)
	if err != nil {
		return nil, fmt.Errorf("could not create Pod from `%s`: %v", source, err)
	}

	pod := Pod{base: base}
	for _, v := range kubePod.Spec.Containers {
		container, err := NewContainer(v, defaults, source)
		if err != nil {
			return nil, err
		}
		pod.containers = append(pod.containers, container)
	}
	kubePod.Spec.Containers = []kube.Container{}

	base.setDefaults(kubePod)
	if err := validatePod(kubePod, true); err != nil {
		return nil, fmt.Errorf("could not create Pod from `%s`: %v", source, err)
	}

	sort.Sort(pod.containers)

	pod.pod = kubePod
	return &pod, nil
}

// NewPodFromPodSpec creates a new Pod using ObjectMeta and a PodSpec.
func NewPodFromPodSpec(meta kube.ObjectMeta, podSpec kube.PodSpec, defaults kube.ObjectMeta, source string, objects ...deploy.KubeObject) (*Pod, error) {