Function TestSourcePods

pkg/input/dir/source_test.go:219–271

(t *testing.T)

}

func TestSourcePods(t *testing.T) {
	fs := testTempFileSource(t)
	defer os.RemoveAll(string(fs))

	podFile := path.Join(string(fs), "test.pod.yaml")

	terminationPeriod := int64(30)
	kubePod := &kube.Pod{
		ObjectMeta: kube.ObjectMeta{
			Name:      "example-pod",
			Namespace: kube.NamespaceDefault,
		},
		TypeMeta: unversioned.TypeMeta{
			Kind:       "Pod",
			APIVersion: "v1",
		},
		Spec: kube.PodSpec{
			Containers: []kube.Container{
				{
					Name:                   "wiki",
					Image:                  "mediawiki",
					ImagePullPolicy:        kube.PullAlways,
					TerminationMessagePath: kube.TerminationMessagePathDefault,
				},
				{
					Name:                   "db",
					Image:                  "postgres",
					ImagePullPolicy:        kube.PullAlways,
					TerminationMessagePath: kube.TerminationMessagePathDefault,
				},
			},
			SecurityContext:               &kube.PodSecurityContext{},
			RestartPolicy:                 kube.RestartPolicyAlways,
			DNSPolicy:                     kube.DNSDefault,
			TerminationGracePeriodSeconds: &terminationPeriod,
		},
	}

	testWriteYAMLToFile(t, podFile, kubePod)

	pods, err := fs.Entities(entity.EntityPod)
	assert.NoError(t, err, "should be okay")
	assert.Len(t, pods, 1, "should have single pod")

	expectedKubePod := kubePod
	testClearTypeInfo(expectedKubePod)

	expected, err := entity.NewPod(expectedKubePod, kube.ObjectMeta{}, podFile)

	actual := pods[0]

	testCompareEntity(t, expected, actual)
}

func TestSourceContainersDir(t *testing.T) {
	fs := testTempFileSource(t)