From 31d8c66f75fe8ce185e4e0bcab4ac9b9877d36ea Mon Sep 17 00:00:00 2001
From: adohe <coolhzb@163.com>
Date: Thu, 30 May 2019 22:03:31 +0800
Subject: [PATCH] :sparkles: Allow setting "UseExistingCluster" via environment

---
 pkg/envtest/server.go | 6 ++++++
 1 file changed, 6 insertions(+)

diff --git a/pkg/envtest/server.go b/pkg/envtest/server.go
index f6801e5519..86527f4198 100644
--- a/pkg/envtest/server.go
+++ b/pkg/envtest/server.go
@@ -20,6 +20,7 @@ import (
 	"fmt"
 	"os"
 	"path/filepath"
+	"strings"
 	"time"
 
 	apiextensionsv1beta1 "k8s.io/apiextensions-apiserver/pkg/apis/apiextensions/v1beta1"
@@ -34,6 +35,7 @@ var log = logf.RuntimeLog.WithName("test-env")
 
 // Default binary path for test framework
 const (
+	envUseExistingCluster  = "USE_EXISTING_CLUSTER"
 	envKubeAPIServerBin    = "TEST_ASSET_KUBE_APISERVER"
 	envEtcdBin             = "TEST_ASSET_ETCD"
 	envKubectlBin          = "TEST_ASSET_KUBECTL"
@@ -122,6 +124,10 @@ func (te Environment) getAPIServerFlags() []string {
 
 // Start starts a local Kubernetes server and updates te.ApiserverPort with the port it is listening on
 func (te *Environment) Start() (*rest.Config, error) {
+	if !te.UseExistingCluster {
+		// Check USE_EXISTING_CLUSTER env then
+		te.UseExistingCluster = strings.ToLower(os.Getenv(envUseExistingCluster)) == "true"
+	}
 	if te.UseExistingCluster {
 		log.V(1).Info("using existing cluster")
 		if te.Config == nil {