From eaea18df0f3b4d7519d2822f24fd888defaefa87 Mon Sep 17 00:00:00 2001 From: Niels de Vos Date: Fri, 7 Aug 2020 10:18:00 +0200 Subject: [PATCH] util: use local FatalLog() for NewK8sClient() instead of klog Signed-off-by: Niels de Vos --- internal/util/k8s.go | 10 +++------- 1 file changed, 3 insertions(+), 7 deletions(-) diff --git a/internal/util/k8s.go b/internal/util/k8s.go index 66333f74f..831bb6bbd 100644 --- a/internal/util/k8s.go +++ b/internal/util/k8s.go @@ -22,7 +22,6 @@ import ( k8s "k8s.io/client-go/kubernetes" "k8s.io/client-go/rest" "k8s.io/client-go/tools/clientcmd" - klog "k8s.io/klog/v2" ) // NewK8sClient create kubernetes client. @@ -33,20 +32,17 @@ func NewK8sClient() *k8s.Clientset { if cPath != "" { cfg, err = clientcmd.BuildConfigFromFlags("", cPath) if err != nil { - klog.Errorf("Failed to get cluster config with error: %v\n", err) - os.Exit(1) + FatalLog("Failed to get cluster config with error: %v\n", err) } } else { cfg, err = rest.InClusterConfig() if err != nil { - klog.Errorf("Failed to get cluster config with error: %v\n", err) - os.Exit(1) + FatalLog("Failed to get cluster config with error: %v\n", err) } } client, err := k8s.NewForConfig(cfg) if err != nil { - klog.Errorf("Failed to create client with error: %v\n", err) - os.Exit(1) + FatalLog("Failed to create client with error: %v\n", err) } return client }