From 99c6602d8c1d8bf9a509c8d64733e8dabb55739a Mon Sep 17 00:00:00 2001 From: Oren Gurfinkel Date: Wed, 22 Jul 2020 17:29:21 +0300 Subject: [PATCH] support inCluster config --- VERSION | 2 +- pkg/kubernetes/kubernetes.go | 9 ++++++++- 2 files changed, 9 insertions(+), 2 deletions(-) diff --git a/VERSION b/VERSION index c9929e3..3c80e4f 100644 --- a/VERSION +++ b/VERSION @@ -1 +1 @@ -1.4.2 \ No newline at end of file +1.4.3 \ No newline at end of file diff --git a/pkg/kubernetes/kubernetes.go b/pkg/kubernetes/kubernetes.go index add486a..59e734f 100644 --- a/pkg/kubernetes/kubernetes.go +++ b/pkg/kubernetes/kubernetes.go @@ -8,6 +8,7 @@ import ( log "github.com/sirupsen/logrus" metav1 "k8s.io/apimachinery/pkg/apis/meta/v1" kubeConfig "k8s.io/client-go/kubernetes" + "k8s.io/client-go/rest" _ "k8s.io/client-go/plugin/pkg/client/auth/gcp" "k8s.io/client-go/tools/clientcmd" "k8s.io/client-go/tools/clientcmd/api" @@ -55,7 +56,12 @@ func goOverContext(options *getOverContextOptions) error { if e != nil { message := fmt.Sprintf("Failed to create config with error:\n%s", e) options.logger.Warn(message) - return e + clientCnf, e = rest.InClusterConfig() + if e != nil { + message = fmt.Sprintf("Failed to create in cluster config with error:\n%s", e) + options.logger.Warn(message) + return e + } } options.logger.Info("Created config for context") host = clientCnf.Host @@ -65,6 +71,7 @@ func goOverContext(options *getOverContextOptions) error { if e != nil { message := fmt.Sprintf("Failed to create kubernetes client with error:\n%s", e) options.logger.Warn(message) + return e } options.logger.Info("Created client set for context")