Function TestSourceRCs

pkg/input/dir/source_test.go:154–217

(t *testing.T)

}

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

	rcFile := path.Join(string(fs), "test.rc.json")

	selector := map[string]string{"app": "example"}

	terminationPeriod := int64(30)
	kubeRC := &kube.ReplicationController{
		ObjectMeta: kube.ObjectMeta{
			Name:      "example-rc",
			Namespace: kube.NamespaceDefault,
		},
		TypeMeta: unversioned.TypeMeta{
			Kind:       "ReplicationController",
			APIVersion: "v1",
		},
		Spec: kube.ReplicationControllerSpec{
			Selector: selector,
			Replicas: 2,
			Template: &kube.PodTemplateSpec{
				ObjectMeta: kube.ObjectMeta{
					Labels: selector,
				},
				Spec: kube.PodSpec{
					Containers: []kube.Container{
						{
							Name:                   "example",
							Image:                  "hello-world",
							ImagePullPolicy:        kube.PullAlways,
							TerminationMessagePath: kube.TerminationMessagePathDefault,
						},
						{
							Name:                   "cache",
							Image:                  "redis",
							ImagePullPolicy:        kube.PullAlways,
							TerminationMessagePath: kube.TerminationMessagePathDefault,
						},
					},
					SecurityContext:               &kube.PodSecurityContext{},
					RestartPolicy:                 kube.RestartPolicyAlways,
					DNSPolicy:                     kube.DNSDefault,
					TerminationGracePeriodSeconds: &terminationPeriod,
				},
			},
		},
	}

	testWriteYAMLToFile(t, rcFile, kubeRC)

	rcs, err := fs.Entities(entity.EntityReplicationController)
	assert.NoError(t, err, "should be okay")
	assert.Len(t, rcs, 1, "should have single rc")

	expectedKubeRC := kubeRC
	testClearTypeInfo(expectedKubeRC)
	expectedKubeRC.Labels = selector