From 644c6226869c1a86a12576a4f4fdab03db0b4369 Mon Sep 17 00:00:00 2001 From: enxebre Date: Wed, 21 Jan 2026 14:15:00 +0100 Subject: [PATCH] Add support to use KUBECONFIG env variable if incluster fails --- cmd/node-termination-handler.go | 6 +++--- 1 file changed, 3 insertions(+), 3 deletions(-) diff --git a/cmd/node-termination-handler.go b/cmd/node-termination-handler.go index edbd1672..ad88edf1 100644 --- a/cmd/node-termination-handler.go +++ b/cmd/node-termination-handler.go @@ -48,7 +48,7 @@ import ( "github.com/rs/zerolog/log" "k8s.io/apimachinery/pkg/util/wait" "k8s.io/client-go/kubernetes" - "k8s.io/client-go/rest" + "k8s.io/client-go/tools/clientcmd" "k8s.io/klog/v2" ) @@ -110,9 +110,9 @@ func main() { log.Fatal().Err(err).Msg("Webhook validation failed,") } - clusterConfig, err := rest.InClusterConfig() + clusterConfig, err := clientcmd.BuildConfigFromFlags("", os.Getenv("KUBECONFIG")) if err != nil { - log.Fatal().Err(err).Msgf("retreiving cluster config") + log.Fatal().Err(err).Msg("retrieving cluster config") } clientset, err := kubernetes.NewForConfig(clusterConfig) if err != nil {