Cr 3334 - support rancher (#220)

roi-codefresh · web-flow · commit dd04ea0b5595 · 2021-02-18T10:34:18.000+02:00
diff --git a/venona/VERSION b/venona/VERSION
@@ -1 +1 @@
-1.5.16
+1.5.17
diff --git a/venonactl/VERSION b/venonactl/VERSION
@@ -1 +1 @@
-1.5.16
+1.5.17
diff --git a/venonactl/cmd/attach.go b/venonactl/cmd/attach.go
@@ -33,6 +33,7 @@ var attachRuntimeCmdOptions struct {
 		context        string
 		kubePath       string
 		serviceAccount string
+		host           string
 	}
 	kubeVenona struct {
 		namespace string
@@ -66,6 +67,7 @@ var attachRuntimeCmd = &cobra.Command{
 
 		mergeValueStr(templateValuesMap, "Namespace", &attachRuntimeCmdOptions.kube.namespace)
 		mergeValueStr(templateValuesMap, "Context", &attachRuntimeCmdOptions.kube.context)
+		mergeValueStr(templateValuesMap, "KubernetesHost", &attachRuntimeCmdOptions.kube.host)
 		mergeValueStr(templateValuesMap, "RuntimeEnvironmentName", &attachRuntimeCmdOptions.runtimeEnvironmentName)
 		mergeValueStr(templateValuesMap, "RuntimeServiceAccount", &attachRuntimeCmdOptions.kube.serviceAccount)
 
@@ -101,6 +103,7 @@ var attachRuntimeCmd = &cobra.Command{
 
 		builderInstallOpt := &plugins.InstallOptions{
 			ClusterNamespace:      attachRuntimeCmdOptions.kubeVenona.namespace,
+			ClusterHost:           attachRuntimeCmdOptions.kube.host,
 			RuntimeEnvironment:    attachRuntimeCmdOptions.runtimeEnvironmentName,
 			RuntimeClusterName:    attachRuntimeCmdOptions.kube.namespace,
 			RuntimeServiceAccount: attachRuntimeCmdOptions.kube.serviceAccount,
@@ -143,6 +146,7 @@ func init() {
 	viper.BindEnv("kube-namespace", "KUBE_NAMESPACE")
 	viper.BindEnv("kube-context", "KUBE_CONTEXT")
 
+	attachRuntimeCmd.Flags().StringVar(&attachRuntimeCmdOptions.kube.host, "kube-host", viper.GetString("kube-host"), "overrides the address of the api-server the runner will use")
 	attachRuntimeCmd.Flags().StringVar(&attachRuntimeCmdOptions.kube.namespace, "kube-namespace", viper.GetString("kube-namespace"), "Name of the namespace on which venona should be installed [$KUBE_NAMESPACE]")
 	attachRuntimeCmd.Flags().StringVar(&attachRuntimeCmdOptions.kube.context, "kube-context-name", viper.GetString("kube-context"), "Name of the kubernetes context on which venona should be installed (default is current-context) [$KUBE_CONTEXT]")
 	attachRuntimeCmd.Flags().StringVar(&attachRuntimeCmdOptions.kube.kubePath, "kube-config-path", viper.GetString("kubeconfig"), "Path to kubeconfig file (default is $HOME/.kube/config) [$KUBECONFIG]")
diff --git a/venonactl/cmd/test.go b/venonactl/cmd/test.go
@@ -34,6 +34,7 @@ var allTestPluginTypes = []string{
 
 var testCommandOptions struct {
 	kube struct {
+		host      string
 		namespace string
 		context   string
 		inCluster bool
@@ -63,6 +64,7 @@ var testCommand = &cobra.Command{
 		mergeValueStr(templateValuesMap, "Token", &cfAPIToken)
 		mergeValueStr(templateValuesMap, "Namespace", &testCommandOptions.kube.namespace)
 		mergeValueStr(templateValuesMap, "Context", &testCommandOptions.kube.context)
+		mergeValueStr(templateValuesMap, "KubernetesHost", &testCommandOptions.kube.host)
 		mergeValueBool(templateValuesMap, "InCluster", &testCommandOptions.kube.inCluster)
 		mergeValueBool(templateValuesMap, "insecure", &testCommandOptions.insecure)
 
@@ -101,7 +103,7 @@ var testCommand = &cobra.Command{
 			}
 		}
 
-		options := plugins.TestOptions{
+		options := &plugins.TestOptions{
 			KubeBuilder:      getKubeClientBuilder(s.KubernetesAPI.ContextName, s.KubernetesAPI.Namespace, s.KubernetesAPI.ConfigPath, s.KubernetesAPI.InCluster, false),
 			ClusterNamespace: s.KubernetesAPI.Namespace,
 		}
@@ -128,6 +130,7 @@ func init() {
 	viper.BindEnv("kube-namespace", "KUBE_NAMESPACE")
 	viper.BindEnv("kube-context", "KUBE_CONTEXT")
 
+	testCommand.Flags().StringVar(&testCommandOptions.kube.host, "kube-host", viper.GetString("kube-host"), "overrides the address of the api-server the runner will use")
 	testCommand.Flags().StringVar(&testCommandOptions.kube.namespace, "kube-namespace", viper.GetString("kube-namespace"), "Name of the namespace on which monitor should be installed [$KUBE_NAMESPACE]")
 	testCommand.Flags().StringVar(&testCommandOptions.kube.context, "kube-context-name", viper.GetString("kube-context"), "Name of the kubernetes context on which monitor should be installed (default is current-context) [$KUBE_CONTEXT]")
 	testCommand.Flags().BoolVar(&testCommandOptions.insecure, "insecure", false, "Set to true to disable certificate validation when using TLS connections")
diff --git a/venonactl/example/values-example.yaml b/venonactl/example/values-example.yaml
@@ -25,7 +25,7 @@
 ###          Kubernetes Context            ###
 ###                                        ###
 ##############################################
-### ConfigPath --kube-config-path $KUBECONFIG: kubeconfig path
+### ConfigPath: --kube-config-path $KUBECONFIG: kubeconfig path
 # ConfigPath: # default is $(HOME)/.kube/config
 
 ### Context: --context $KUBE_CONTEXT: which kubernetes context to use
@@ -48,9 +48,17 @@
 ### default is: runner
 # RuntimeServiceAccount: runner
 
+### KubernetesHost: --kube-host: used when attaching a runtime to a runner to override the
+### apiserver address that the runner will use to create resources on the runtime,
+### by default we use the host from your kubeconfig.
+# KubernetesHost: https://kubernetes.default.svc.cluster.local
+
 ### SkipClusterTest: only set to true if you want to skip the acceptance tests during the installation
 # SkipClusterTest: true
 
+### SkipClusterTest: if set to true, cluster integration will not be created in Codefresh
+# SkipClusterIntegration: false
+
 ### ClusterId --clusterId: used when installing the monitor component
 ### this is the name of the cluster integration in codefresh
 # ClusterId: cluster-name
diff --git a/venonactl/go.sum b/venonactl/go.sum
@@ -135,6 +135,7 @@ github.com/docker/spdystream v0.0.0-20160310174837-449fdfce4d96/go.mod h1:Qh8CwZ
 github.com/dustin/go-humanize v0.0.0-20171111073723-bb3d318650d4/go.mod h1:HtrtbFcZ19U5GC7JDqmcUSB87Iq5E25KnS6fMYU6eOk=
 github.com/dustin/go-humanize v1.0.0 h1:VSnTsYCnlFHaM2/igO1h6X3HA71jcobQuxemgkq4zYo=
 github.com/dustin/go-humanize v1.0.0/go.mod h1:HtrtbFcZ19U5GC7JDqmcUSB87Iq5E25KnS6fMYU6eOk=
+github.com/elazarl/goproxy v0.0.0-20170405201442-c4fc26588b6e h1:p1yVGRW3nmb85p1Sh1ZJSDm4A4iKLS5QNbvUHMgGu/M=
 github.com/elazarl/goproxy v0.0.0-20170405201442-c4fc26588b6e/go.mod h1:/Zj4wYkgs4iZTTu3o/KG3Itv/qCCa8VVMlb3i9OVuzc=
 github.com/emicklei/go-restful v0.0.0-20170410110728-ff4f55a20633/go.mod h1:otzb+WCGbkyDHkqmQmT5YD2WR4BBwUdeQoFo8l/7tVs=
 github.com/emicklei/go-restful v2.9.5+incompatible h1:spTtZBk5DYEvbxMVutUuTyh1Ao2r4iyvLdACqsl/Ljk=
@@ -221,6 +222,7 @@ github.com/gogo/protobuf v1.3.1 h1:DqDEcV5aeaTmdFBePNpYsp3FlcVH/2ISVVM9Qf8PSls=
 github.com/gogo/protobuf v1.3.1/go.mod h1:SlYgWuQ5SjCEi6WLHjHCa1yvBfUnHcTbrrZtXPKa29o=
 github.com/golang/glog v0.0.0-20160126235308-23def4e6c14b/go.mod h1:SBH7ygxi8pfUlaOkMMuAQtPIUF8ecWP5IEl/CR7VP2Q=
 github.com/golang/groupcache v0.0.0-20160516000752-02826c3e7903/go.mod h1:cIg4eruTrX1D+g88fzRXU5OdNfaM+9IcxsU14FzY7Hc=
+github.com/golang/groupcache v0.0.0-20190129154638-5b532d6fd5ef h1:veQD95Isof8w9/WXiA+pa3tz3fJXkt5B7QaRBrM62gk=
 github.com/golang/groupcache v0.0.0-20190129154638-5b532d6fd5ef/go.mod h1:cIg4eruTrX1D+g88fzRXU5OdNfaM+9IcxsU14FzY7Hc=
 github.com/golang/mock v1.1.1/go.mod h1:oTYuIxOrZwtPieC+H1uAHpcLFnEyAGVDL/k47Jfbm0A=
 github.com/golang/mock v1.2.0/go.mod h1:oTYuIxOrZwtPieC+H1uAHpcLFnEyAGVDL/k47Jfbm0A=
@@ -274,6 +276,7 @@ github.com/hashicorp/golang-lru v0.5.1 h1:0hERBMJE1eitiLkihrMvRVBYAkpHzc/J3QdDN+
 github.com/hashicorp/golang-lru v0.5.1/go.mod h1:/m3WP610KZHVQ1SGc6re/UDhFvYD7pJ4Ao+sR/qLZy8=
 github.com/hashicorp/hcl v1.0.0 h1:0Anlzjpi4vEasTeNFn2mLJgTSwt0+6sfsiTG8qcWGx4=
 github.com/hashicorp/hcl v1.0.0/go.mod h1:E5yfLk+7swimpb2L/Alb/PJmXilQ/rhwaUYs4T20WEQ=
+github.com/hpcloud/tail v1.0.0 h1:nfCOvKYfkgYP8hkirhJocXT2+zOD8yUNjXaWfTlyFKI=
 github.com/hpcloud/tail v1.0.0/go.mod h1:ab1qPbhIpdTxEkNHXyeSf5vhxWSCs/tWer42PpOxQnU=
 github.com/huandu/xstrings v1.2.0/go.mod h1:DvyZB1rfVYsBIigL8HwpZgxHwXozlTgGqn63UyNX5k4=
 github.com/huandu/xstrings v1.3.0 h1:gvV6jG9dTgFEncxo+AF7PH6MZXi/vZl25owA/8Dg8Wo=
@@ -370,8 +373,10 @@ github.com/olekukonko/tablewriter v0.0.4 h1:vHD/YYe1Wolo78koG299f7V/VAS08c6IpCLn
 github.com/olekukonko/tablewriter v0.0.4/go.mod h1:zq6QwlOf5SlnkVbMSr5EoBv3636FWnp+qbPhuoO21uA=
 github.com/onsi/ginkgo v0.0.0-20170829012221-11459a886d9c/go.mod h1:lLunBs/Ym6LB5Z9jYTR76FiuTmxDTDusOGeTQH+WWjE=
 github.com/onsi/ginkgo v1.6.0/go.mod h1:lLunBs/Ym6LB5Z9jYTR76FiuTmxDTDusOGeTQH+WWjE=
+github.com/onsi/ginkgo v1.10.1 h1:q/mM8GF/n0shIN8SaAZ0V+jnLPzen6WIVZdiwrRlMlo=
 github.com/onsi/ginkgo v1.10.1/go.mod h1:lLunBs/Ym6LB5Z9jYTR76FiuTmxDTDusOGeTQH+WWjE=
 github.com/onsi/gomega v0.0.0-20170829124025-dcabb60a477c/go.mod h1:C1qb7wdrVGGVU+Z6iS04AVkA3Q65CEZX59MT0QO5uiA=
+github.com/onsi/gomega v1.7.0 h1:XPnZz8VVBHjVsy1vzJmRwIcSwiUO+JFfrv/xGiigmME=
 github.com/onsi/gomega v1.7.0/go.mod h1:ex+gbHU/CVuBBDIJjb2X0qEXbFg53c61hWP/1CpauHY=
 github.com/opencontainers/go-digest v0.0.0-20170106003457-a6d0ee40d420/go.mod h1:cMLVZDEM3+U2I4VmLI6N8jQYUd2OVphdqWwCJHrFt2s=
 github.com/opencontainers/go-digest v0.0.0-20180430190053-c9281466c8b2/go.mod h1:cMLVZDEM3+U2I4VmLI6N8jQYUd2OVphdqWwCJHrFt2s=
@@ -642,6 +647,7 @@ gopkg.in/check.v1 v1.0.0-20180628173108-788fd7840127/go.mod h1:Co6ibVJAznAaIkqp8
 gopkg.in/check.v1 v1.0.0-20190902080502-41f04d3bba15 h1:YR8cESwS4TdDjEe65xsg0ogRM/Nc3DYOhEAlW+xobZo=
 gopkg.in/check.v1 v1.0.0-20190902080502-41f04d3bba15/go.mod h1:Co6ibVJAznAaIkqp8huTwlJQCZ016jof/cbN4VW5Yz0=
 gopkg.in/cheggaaa/pb.v1 v1.0.25/go.mod h1:V/YB90LKu/1FcN3WVnfiiE5oMCibMjukxqG/qStrOgw=
+gopkg.in/fsnotify.v1 v1.4.7 h1:xOHLXZwVvI9hhs+cLKq5+I5onOuwQLhQwiu63xxlHs4=
 gopkg.in/fsnotify.v1 v1.4.7/go.mod h1:Tz8NjZHkW78fSQdbUxIjBTcgA1z1m8ZHf0WmKUhAMys=
 gopkg.in/gemnasium/logrus-airbrake-hook.v2 v2.1.2/go.mod h1:Xk6kEKp8OKb+X14hQBKWaSkCsqBpgog8nAV2xsGOxlo=
 gopkg.in/inf.v0 v0.9.1 h1:73M5CoZyi3ZLMOyDlQh031Cx6N9NDJ2Vvfl76EDAgDc=
@@ -651,6 +657,7 @@ gopkg.in/ini.v1 v1.51.0/go.mod h1:pNLf8WUiyNEtQjuu5G5vTm06TEv9tsIgeAvK8hOrP4k=
 gopkg.in/natefinch/lumberjack.v2 v2.0.0/go.mod h1:l0ndWWf7gzL7RNwBG7wST/UCcT4T24xpD6X8LsfU/+k=
 gopkg.in/resty.v1 v1.12.0/go.mod h1:mDo4pnntr5jdWRML875a/NmxYqAlA73dVijT2AXvQQo=
 gopkg.in/square/go-jose.v2 v2.2.2/go.mod h1:M9dMgbHiYLoDGQrXy7OpJDJWiKiU//h+vD76mk0e1AI=
+gopkg.in/tomb.v1 v1.0.0-20141024135613-dd632973f1e7 h1:uRGJdciOHaEIrze2W8Q3AKkepLTh2hOroT7a+7czfdQ=
 gopkg.in/tomb.v1 v1.0.0-20141024135613-dd632973f1e7/go.mod h1:dt/ZhP58zS4L8KSrWDmTeBkI65Dw0HsyUHuEVlX15mw=
 gopkg.in/yaml.v2 v2.0.0-20170812160011-eb3733d160e7/go.mod h1:JAlM8MvJe8wmxCU4Bli9HhUf9+ttbYbLASfIpnQbh74=
 gopkg.in/yaml.v2 v2.2.1/go.mod h1:hI93XBmqTisBFMUTm0b8Fm+jr3Dg1NNxqwp+5A1VGuI=
@@ -659,11 +666,10 @@ gopkg.in/yaml.v2 v2.2.4/go.mod h1:hI93XBmqTisBFMUTm0b8Fm+jr3Dg1NNxqwp+5A1VGuI=
 gopkg.in/yaml.v2 v2.2.7/go.mod h1:hI93XBmqTisBFMUTm0b8Fm+jr3Dg1NNxqwp+5A1VGuI=
 gopkg.in/yaml.v2 v2.2.8 h1:obN1ZagJSUGI0Ek/LBmuj4SNLPfIny3KsKFopxRdj10=
 gopkg.in/yaml.v2 v2.2.8/go.mod h1:hI93XBmqTisBFMUTm0b8Fm+jr3Dg1NNxqwp+5A1VGuI=
+gotest.tools v2.2.0+incompatible h1:VsBPFP1AI068pPrMxtb/S8Zkgf9xEmTLJjfM+P5UIEo=
 gotest.tools v2.2.0+incompatible/go.mod h1:DsYFclhRJ6vuDpmuTbkuFWG+y2sxOXAzmJt81HFBacw=
-helm.sh/helm v2.16.9+incompatible h1:31XFG6KPAbh2A/oDgIaQFR8L63vtyxN7tOt64URUJvY=
 helm.sh/helm/v3 v3.1.1 h1:aykwPMVyQyncZ8iLNVMXgJ1l3c6W0+LSOPmqp8JdCjs=
 helm.sh/helm/v3 v3.1.1/go.mod h1:WYsFJuMASa/4XUqLyv54s0U/f3mlAaRErGmyy4z921g=
-helm.sh/helm/v3 v3.2.4 h1:lz/0ZRkSgyIF+pCo6pjFzap1udCARB1IN6CRfqkpcOg=
 honnef.co/go/tools v0.0.0-20190102054323-c2f93a96b099/go.mod h1:rf3lG4BRIbNafJWhAfAdb/ePZxsR/4RtNHQocxwk9r4=
 honnef.co/go/tools v0.0.0-20190106161140-3f1c8253044a/go.mod h1:rf3lG4BRIbNafJWhAfAdb/ePZxsR/4RtNHQocxwk9r4=
 honnef.co/go/tools v0.0.0-20190523083050-ea95bdfd59fc/go.mod h1:rf3lG4BRIbNafJWhAfAdb/ePZxsR/4RtNHQocxwk9r4=
@@ -675,14 +681,12 @@ k8s.io/apiextensions-apiserver v0.17.2/go.mod h1:4KdMpjkEjjDI2pPfBA15OscyNldHWdB
 k8s.io/apimachinery v0.17.2/go.mod h1:b9qmWdKlLuU9EBh+06BtLcSf/Mu89rWL33naRxs1uZg=
 k8s.io/apimachinery v0.17.3 h1:f+uZV6rm4/tHE7xXgLyToprg6xWairaClGVkm2t8omg=
 k8s.io/apimachinery v0.17.3/go.mod h1:gxLnyZcGNdZTCLnq3fgzyg2A5BVCHTNDFrw8AmuJ+0g=
-k8s.io/apimachinery v0.18.6 h1:RtFHnfGNfd1N0LeSrKCUznz5xtUP1elRGvHJbL3Ntag=
 k8s.io/apiserver v0.17.2/go.mod h1:lBmw/TtQdtxvrTk0e2cgtOxHizXI+d0mmGQURIHQZlo=
 k8s.io/cli-runtime v0.17.2 h1:YH4txSplyGudvxjhAJeHEtXc7Tr/16clKGfN076ydGk=
 k8s.io/cli-runtime v0.17.2/go.mod h1:aa8t9ziyQdbkuizkNLAw3qe3srSyWh9zlSB7zTqRNPI=
 k8s.io/client-go v0.17.2/go.mod h1:QAzRgsa0C2xl4/eVpeVAZMvikCn8Nm81yqVx3Kk9XYI=
 k8s.io/client-go v0.17.3 h1:deUna1Ksx05XeESH6XGCyONNFfiQmDdqeqUvicvP6nU=
 k8s.io/client-go v0.17.3/go.mod h1:cLXlTMtWHkuK4tD360KpWz2gG2KtdWEr/OT02i3emRQ=
-k8s.io/client-go v11.0.0+incompatible h1:LBbX2+lOwY9flffWlJM7f1Ct8V2SRNiMRDFeiwnJo9o=
 k8s.io/code-generator v0.17.2/go.mod h1:DVmfPQgxQENqDIzVR2ddLXMH34qeszkKSdH/N+s+38s=
 k8s.io/component-base v0.17.2 h1:0XHf+cerTvL9I5Xwn9v+0jmqzGAZI7zNydv4tL6Cw6A=
 k8s.io/component-base v0.17.2/go.mod h1:zMPW3g5aH7cHJpKYQ/ZsGMcgbsA/VyhEugF3QT1awLs=
diff --git a/venonactl/pkg/kube/kube.go b/venonactl/pkg/kube/kube.go
@@ -58,12 +58,11 @@ func (k *kube) BuildClient() (*kubernetes.Clientset, error) {
 	if err != nil {
 		return nil, err
 	}
-	cs, err := kubernetes.NewForConfig(config)
-	return cs, nil
+	return kubernetes.NewForConfig(config)
 }
 
 func (k *kube) EnsureNamespaceExists(cs *kubernetes.Clientset) error {
-	if k.dryRun == true {
+	if k.dryRun {
 		return nil
 	}
 	_, err := cs.CoreV1().Namespaces().Get(k.namespace, v1.GetOptions{})
diff --git a/venonactl/pkg/plugins/app-proxy.go b/venonactl/pkg/plugins/app-proxy.go
@@ -122,7 +122,7 @@ func (u *appProxyPlugin) Migrate(*MigrateOptions, Values) error {
 	return fmt.Errorf("not supported")
 }
 
-func (u *appProxyPlugin) Test(opt TestOptions, v Values) error {
+func (u *appProxyPlugin) Test(opt *TestOptions, v Values) error {
 	return nil
 }
 
diff --git a/venonactl/pkg/plugins/engine.go b/venonactl/pkg/plugins/engine.go
@@ -101,7 +101,7 @@ func (u *enginePlugin) Migrate(*MigrateOptions, Values) error {
 	return fmt.Errorf("not supported")
 }
 
-func (u *enginePlugin) Test(opt TestOptions, v Values) error {
+func (u *enginePlugin) Test(opt *TestOptions, v Values) error {
 	return nil
 }
 
diff --git a/venonactl/pkg/plugins/monitor.go b/venonactl/pkg/plugins/monitor.go
@@ -86,7 +86,7 @@ func (u *monitorAgentPlugin) Migrate(*MigrateOptions, Values) error {
 	return fmt.Errorf("not supported")
 }
 
-func (u *monitorAgentPlugin) Test(opt TestOptions, v Values) error {
+func (u *monitorAgentPlugin) Test(opt *TestOptions, v Values) error {
 	validationRequest := validationRequest{
 		rbac: []rbacValidation{
 			{
diff --git a/venonactl/pkg/plugins/network-tester.go b/venonactl/pkg/plugins/network-tester.go
@@ -46,7 +46,11 @@ const (
 )
 
 var (
-	errNetworkTestFailed = errors.New("Cluster network tests failed. If you are using a proxy, run again with the correct http proxy environment variables. For more details run again with --verbose")
+	errNetworkTestFailed = errors.New(`Cluster network tests failed.
+- If you are using a proxy, run again with the correct http proxy environment variables.
+- Make sure that cluster host address in your kubeconfig is accessible from inside the cluster,
+  or specify a different one with: --set-value KubernetesHost=<address>.
+For more details run again with --verbose`)
 )
 
 func (u *networkTesterPlugin) Install(opt *InstallOptions, v Values) (Values, error) {
@@ -102,7 +106,16 @@ func prepareTestDomains(v map[string]interface{}) []string {
 	return testDomains
 }
 
-func (u *networkTesterPlugin) Test(opt TestOptions, v Values) error {
+func getKubeHost(v map[string]interface{}, defaultHost string) string {
+	vObj := objx.New(v)
+	if host := vObj.Get("KubernetesHost").Str(); host != "" {
+		return host
+	}
+
+	return defaultHost
+}
+
+func (u *networkTesterPlugin) Test(opt *TestOptions, v Values) error {
 	cs, err := opt.KubeBuilder.BuildClient()
 	if err != nil {
 		u.logger.Error(fmt.Sprintf("Cannot create kubernetes clientset: %v ", err))
@@ -114,9 +127,15 @@ func (u *networkTesterPlugin) Test(opt TestOptions, v Values) error {
 		return err
 	}
 
+	conf, err := opt.KubeBuilder.BuildConfig()
+	if err != nil {
+		return fmt.Errorf("failed to build config: %w", err)
+	}
+
 	testDomains := prepareTestDomains(v)
 	urls := strings.Join(testDomains, ",")
 	objx.New(v["NetworkTester"]).Set("AdditionalEnvVars.URLS", urls)
+	objx.New(v["NetworkTester"]).Set("AdditionalEnvVars.KUBERNETES_HOST", getKubeHost(v, conf.Host))
 
 	err = install(&installOptions{
 		logger:         u.logger,
diff --git a/venonactl/pkg/plugins/plugin.go b/venonactl/pkg/plugins/plugin.go
@@ -32,7 +32,7 @@ type (
 		Delete(*DeleteOptions, Values) error
 		Upgrade(*UpgradeOptions, Values) (Values, error)
 		Migrate(*MigrateOptions, Values) error
-		Test(TestOptions, Values) error
+		Test(*TestOptions, Values) error
 		Name() string
 	}
 
@@ -57,6 +57,7 @@ type (
 		CodefreshToken        string
 		ClusterName           string
 		ClusterNamespace      string
+		ClusterHost           string
 		RegisterWithAgent     bool
 		MarkAsDefault         bool
 		StorageClass          string
@@ -114,6 +115,7 @@ type (
 	TestOptions struct {
 		KubeBuilder interface {
 			BuildClient() (*kubernetes.Clientset, error)
+			BuildConfig() (*rest.Config, error)
 			EnsureNamespaceExists(cs *kubernetes.Clientset) error
 		}
 		ClusterNamespace string
diff --git a/venonactl/pkg/plugins/runtime-attach.go b/venonactl/pkg/plugins/runtime-attach.go
@@ -76,10 +76,15 @@ func buildRuntimeConfig(opt *InstallOptions, v Values) (RuntimeConfiguration, er
 	crt := secret.Data["ca.crt"]
 	token := secret.Data["token"]
 
+	host := config.Host
+	if opt.ClusterHost != "" {
+		host = opt.ClusterHost
+	}
+
 	rc := RuntimeConfiguration{
 		Crt:   string(crt),
 		Token: string(token),
-		Host:  config.Host,
+		Host:  host,
 		Name:  opt.RuntimeEnvironment,
 		Type:  "runtime",
 	}
@@ -110,7 +115,7 @@ func readCurrentVenonaConf(agentKubeBuilder KubeClientBuilder, clusterNamespace
 }
 
 func (u *runtimeAttachPlugin) Install(opt *InstallOptions, v Values) (Values, error) {
-	if opt.DryRun == true {
+	if opt.DryRun {
 		return v, nil
 	}
 	cs, err := opt.AgentKubeBuilder.BuildClient() // on the agent cluster
@@ -310,7 +315,7 @@ func (u *runtimeAttachPlugin) Migrate(*MigrateOptions, Values) error {
 	return fmt.Errorf("not supported")
 }
 
-func (u *runtimeAttachPlugin) Test(opt TestOptions, v Values) error {
+func (u *runtimeAttachPlugin) Test(opt *TestOptions, v Values) error {
 	return nil
 }
 
diff --git a/venonactl/pkg/plugins/runtime-environment.go b/venonactl/pkg/plugins/runtime-environment.go
@@ -148,7 +148,7 @@ func (u *runtimeEnvironmentPlugin) Migrate(opt *MigrateOptions, v Values) error
 	}, v)
 }
 
-func (u *runtimeEnvironmentPlugin) Test(opt TestOptions, v Values) error {
+func (u *runtimeEnvironmentPlugin) Test(opt *TestOptions, v Values) error {
 	validationRequest := validationRequest{
 		rbac: []rbacValidation{
 			{
diff --git a/venonactl/pkg/plugins/venona.go b/venonactl/pkg/plugins/venona.go
@@ -343,7 +343,7 @@ func (u *venonaPlugin) Migrate(opt *MigrateOptions, v Values) error {
 	}
 }
 
-func (u *venonaPlugin) Test(opt TestOptions, v Values) error {
+func (u *venonaPlugin) Test(opt *TestOptions, v Values) error {
 	validationRequest := validationRequest{
 		cpu:        "500m",
 		momorySize: "1Gi",
diff --git a/venonactl/pkg/plugins/volume-provisioner.go b/venonactl/pkg/plugins/volume-provisioner.go
@@ -115,7 +115,7 @@ func (u *volumeProvisionerPlugin) Migrate(opt *MigrateOptions, v Values) error {
 	}, v)
 }
 
-func (u *volumeProvisionerPlugin) Test(opt TestOptions, v Values) error {
+func (u *volumeProvisionerPlugin) Test(opt *TestOptions, v Values) error {
 	validationRequest := validationRequest{
 		rbac: []rbacValidation{
 			{

Original file line number	Diff line number	Diff line change
`@@ -58,12 +58,11 @@ func (k kube) BuildClient() (kubernetes.Clientset, error) {`
`58`	`58`	`if err != nil {`
`59`	`59`	`return nil, err`
`60`	`60`	`}`
`61`		`- cs, err := kubernetes.NewForConfig(config)`
`62`		`- return cs, nil`
	`61`	`+ return kubernetes.NewForConfig(config)`
`63`	`62`	`}`
`64`	`63`
`65`	`64`	`func (k kube) EnsureNamespaceExists(cs kubernetes.Clientset) error {`
`66`		`- if k.dryRun == true {`
	`65`	`+ if k.dryRun {`
`67`	`66`	`return nil`
`68`	`67`	`}`
`69`	`68`	`_, err := cs.CoreV1().Namespaces().Get(k.namespace, v1.GetOptions{})`
Original file line number	Diff line number	Diff line change
`@@ -122,7 +122,7 @@ func (u appProxyPlugin) Migrate(MigrateOptions, Values) error {`
`122`	`122`	`return fmt.Errorf("not supported")`
`123`	`123`	`}`
`124`	`124`
`125`		`-func (u *appProxyPlugin) Test(opt TestOptions, v Values) error {`
	`125`	`+func (u appProxyPlugin) Test(opt TestOptions, v Values) error {`
`126`	`126`	`return nil`
`127`	`127`	`}`
`128`	`128`
Original file line number	Diff line number	Diff line change
`@@ -101,7 +101,7 @@ func (u enginePlugin) Migrate(MigrateOptions, Values) error {`
`101`	`101`	`return fmt.Errorf("not supported")`
`102`	`102`	`}`
`103`	`103`
`104`		`-func (u *enginePlugin) Test(opt TestOptions, v Values) error {`
	`104`	`+func (u enginePlugin) Test(opt TestOptions, v Values) error {`
`105`	`105`	`return nil`
`106`	`106`	`}`
`107`	`107`
Original file line number	Diff line number	Diff line change
`@@ -86,7 +86,7 @@ func (u monitorAgentPlugin) Migrate(MigrateOptions, Values) error {`
`86`	`86`	`return fmt.Errorf("not supported")`
`87`	`87`	`}`
`88`	`88`
`89`		`-func (u *monitorAgentPlugin) Test(opt TestOptions, v Values) error {`
	`89`	`+func (u monitorAgentPlugin) Test(opt TestOptions, v Values) error {`
`90`	`90`	`validationRequest := validationRequest{`
`91`	`91`	`rbac: []rbacValidation{`
`92`	`92`	`{`