feat: add user impersonation to all commands

docs/cli.md

@@ -61,6 +61,10 @@ Flags are:
 
   Directory to output kind logs to (if not specified, the current working directory).
 
+* **`--as (string)`**
+
+  The kubernetes user to impersonate for the operation. User could be a regular user or a service account in a namespace.
+
 * **`--config (string)`**
 
   Path to file to load test settings from. This is usually the `kuttl-test.yaml` file.

pkg/k8s/main.go

@@ -0,0 +1,21 @@
+package k8s
+
+import (
+	"k8s.io/client-go/rest"
+	"sigs.k8s.io/controller-runtime/pkg/client/config"
+)
+
+var ImpersonateAs = ""
+
+func GetConfig() (*rest.Config, error) {
+	cfg, err := config.GetConfig()
+	if err != nil {
+		return nil, err
+	}
+
+	if ImpersonateAs != "" {
+		cfg.Impersonate.UserName = ImpersonateAs
+	}
+
+	return cfg, nil
+}

pkg/kuttlctl/cmd/root.go

@@ -3,6 +3,7 @@ package cmd
 import (
 	"github.com/spf13/cobra"
 
+	"github.com/kudobuilder/kuttl/pkg/k8s"
 	"github.com/kudobuilder/kuttl/pkg/version"
 )
 
@@ -30,6 +31,7 @@ and serves as an API aggregation layer.
 		Version: version.Get().GitVersion,
 	}
 
+	cmd.PersistentFlags().StringVar(&k8s.ImpersonateAs, "as", "", "Username to impersonate for the operation. User could be a regular user or a service account in a namespace.")
 	cmd.AddCommand(newAssertCmd())
 	cmd.AddCommand(newErrorsCmd())
 	cmd.AddCommand(newTestCmd())

pkg/test/assert.go

@@ -7,8 +7,8 @@ import (
 
 	"k8s.io/client-go/discovery"
 	"sigs.k8s.io/controller-runtime/pkg/client"
-	"sigs.k8s.io/controller-runtime/pkg/client/config"
 
+	"github.com/kudobuilder/kuttl/pkg/k8s"
 	testutils "github.com/kudobuilder/kuttl/pkg/test/utils"
 )
 
@@ -105,27 +105,31 @@ func Errors(namespace string, timeout int, errorFiles ...string) error {
 }
 
 func Client(_ bool) (client.Client, error) {
-	cfg, err := config.GetConfig()
+	cfg, err := k8s.GetConfig()
 	if err != nil {
 		return nil, err
 	}
+
 	client, err := testutils.NewRetryClient(cfg, client.Options{
 		Scheme: testutils.Scheme(),
 	})
 	if err != nil {
 		return nil, fmt.Errorf("fatal error getting client: %v", err)
 	}
+
 	return client, nil
 }
 
 func DiscoveryClient() (discovery.DiscoveryInterface, error) {
-	cfg, err := config.GetConfig()
+	cfg, err := k8s.GetConfig()
 	if err != nil {
 		return nil, err
 	}
+
 	dclient, err := discovery.NewDiscoveryClientForConfig(cfg)
 	if err != nil {
 		return nil, fmt.Errorf("fatal error getting discovery client: %v", err)
 	}
+
 	return dclient, nil
 }

pkg/test/harness.go

@@ -24,13 +24,13 @@ import (
 	"k8s.io/client-go/rest"
 	"k8s.io/client-go/tools/clientcmd"
 	"sigs.k8s.io/controller-runtime/pkg/client"
-	"sigs.k8s.io/controller-runtime/pkg/client/config"
 	"sigs.k8s.io/controller-runtime/pkg/envtest"
 	kindConfig "sigs.k8s.io/kind/pkg/apis/config/v1alpha4"
 
 	harness "github.com/kudobuilder/kuttl/pkg/apis/testharness/v1beta1"
 	"github.com/kudobuilder/kuttl/pkg/file"
 	"github.com/kudobuilder/kuttl/pkg/http"
+	"github.com/kudobuilder/kuttl/pkg/k8s"
 	"github.com/kudobuilder/kuttl/pkg/report"
 	testutils "github.com/kudobuilder/kuttl/pkg/test/utils"
 )
@@ -253,7 +253,7 @@ func (h *Harness) Config() (*rest.Config, error) {
 		h.config, err = h.RunKIND()
 	default:
 		h.T.Log("running tests using configured kubeconfig.")
-		h.config, err = config.GetConfig()
+		h.config, err = k8s.GetConfig()
 		if err != nil {
 			return nil, err
 		}