commands/.../test/cluster.go: add flag for service account

Author: AlexNPavel

commands/operator-sdk/cmd/test/cluster.go

@@ -33,6 +33,7 @@ var (
 	testNamespace     string
 	kubeconfigCluster string
 	imagePullPolicy   string
+	serviceAccount    string
 	pendingTimeout    int
 )
 
@@ -50,7 +51,8 @@ func NewTestClusterCmd() *cobra.Command {
 	testCmd.Flags().StringVarP(&testNamespace, "namespace", "n", "default", "Namespace to run tests in")
 	testCmd.Flags().StringVarP(&kubeconfigCluster, "kubeconfig", "k", defaultKubeConfig, "Kubeconfig path")
 	testCmd.Flags().StringVarP(&imagePullPolicy, "imagePullPolicy", "i", "Always", "Set test pod image pull policy. Allowed values: Always, Never")
-	testCmd.Flags().IntVarP(&pendingTimeout, "pendingTimout", "p", 60, "Timeout for testing pod in pending state")
+	testCmd.Flags().StringVarP(&serviceAccount, "serviceAccount", "s", "default", "Service account to run tests on")
+	testCmd.Flags().IntVarP(&pendingTimeout, "pendingTimeout", "p", 60, "Timeout for testing pod in pending state")
 
 	return testCmd
 }
@@ -77,7 +79,8 @@ func testClusterFunc(cmd *cobra.Command, args []string) error {
 			Name: "operator-test",
 		},
 		Spec: v1.PodSpec{
-			RestartPolicy: v1.RestartPolicyNever,
+			ServiceAccountName: serviceAccount,
+			RestartPolicy:      v1.RestartPolicyNever,
 			Containers: []v1.Container{{
 				Name:            "operator-test",
 				Image:           args[0],

test/e2e/memcached_test.go

@@ -327,6 +327,17 @@ func MemcachedClusterTest(t *testing.T) {
 	ctx := f.NewTestCtx(t)
 	defer ctx.Cleanup(t)
 
+	// create sa
+	saYAML, err := ioutil.ReadFile("deploy/sa.yaml")
+	if err != nil {
+		t.Fatal(err)
+	}
+	err = ctx.CreateFromYAML(saYAML)
+	if err != nil {
+		t.Fatal(err)
+	}
+	t.Log("Created sa")
+
 	// create rbac
 	rbacYAML, err := ioutil.ReadFile("deploy/rbac.yaml")
 	err = ctx.CreateFromYAML(rbacYAML)
@@ -339,7 +350,7 @@ func MemcachedClusterTest(t *testing.T) {
 	if err != nil {
 		t.Fatalf("could not get namespace: %v", err)
 	}
-	cmdOut, err := exec.Command("operator-sdk", "test", "cluster", *f.ImageName, "-n", namespace, "-i", "Never").CombinedOutput()
+	cmdOut, err := exec.Command("operator-sdk", "test", "cluster", *f.ImageName, "-n", namespace, "-i", "Never", "-s", "memcached-operator").CombinedOutput()
 	if err != nil {
 		t.Fatalf("in-cluster test failed: %v\nCommand Output:\n%s", err, string(cmdOut))
 	}