Merge branch 'master' into Update-path-creation-and-save-data-after-removing-PV

cmd/nfs-subdir-external-provisioner/provisioner.go

@@ -28,12 +28,14 @@ import (
 
 	"github.com/golang/glog"
 	v1 "k8s.io/api/core/v1"
+
 	storage "k8s.io/api/storage/v1"
 	metav1 "k8s.io/apimachinery/pkg/apis/meta/v1"
 	"k8s.io/apimachinery/pkg/util/wait"
 	"k8s.io/client-go/kubernetes"
 	"k8s.io/client-go/rest"
 	"k8s.io/kubernetes/pkg/apis/core/v1/helper"
+	"k8s.io/client-go/tools/clientcmd"
 	"sigs.k8s.io/sig-storage-lib-external-provisioner/controller"
 )
 
@@ -214,12 +216,24 @@ func main() {
 	if provisionerName == "" {
 		glog.Fatalf("environment variable %s is not set! Please set it.", provisionerNameKey)
 	}
-
+	kubeconfig := os.Getenv("KUBECONFIG")
-	// Create an InClusterConfig and use it to create a client for the controller
+	var config *rest.Config
-	// to use to communicate with Kubernetes
+	if kubeconfig != "" {
-	config, err := rest.InClusterConfig()
+		// Create an OutOfClusterConfig and use it to create a client for the controller
-	if err != nil {
+		// to use to communicate with Kubernetes
-		glog.Fatalf("Failed to create config: %v", err)
+		var err error
+		config, err = clientcmd.BuildConfigFromFlags("", kubeconfig)
+		if err != nil {
+			glog.Fatalf("Failed to create kubeconfig: %v", err)
+		}
+	} else {
+		// Create an InClusterConfig and use it to create a client for the controller
+		// to use to communicate with Kubernetes
+		var err error
+		config, err = rest.InClusterConfig()
+		if err != nil {
+			glog.Fatalf("Failed to create config: %v", err)
+		}
 	}
 	clientset, err := kubernetes.NewForConfig(config)
 	if err != nil {