From 2ae5733cbcbdab4a6647b11c8149ca4bb19010f9 Mon Sep 17 00:00:00 2001
From: williamlee <909445583@qq.com>
Date: Wed, 30 Mar 2022 17:39:13 +0800
Subject: [PATCH] add 'configPath not exist' log
---
internal/commands/root/root.go | 5 +++--
1 file changed, 3 insertions(+), 2 deletions(-)
diff --git a/internal/commands/root/root.go b/internal/commands/root/root.go
index 095ccfb..c986be2 100644
--- a/internal/commands/root/root.go
+++ b/internal/commands/root/root.go
@@ -73,7 +73,7 @@ func runRootCommand(ctx context.Context, s *provider.Store, c *opts.Opts) error
return errors.Errorf("provider %q not found", c.Provider)
}
- client, err := newClient(c.KubeConfigPath, c.KubeAPIQPS, c.KubeAPIBurst)
+ client, err := newClient(ctx, c.KubeConfigPath, c.KubeAPIQPS, c.KubeAPIBurst)
if err != nil {
return err
}
@@ -279,7 +279,7 @@ func waitFor(ctx context.Context, time time.Duration, ready <-chan struct{}) err
}
}
-func newClient(configPath string, qps, burst int32) (*kubernetes.Clientset, error) {
+func newClient(ctx context.Context, configPath string, qps, burst int32) (*kubernetes.Clientset, error) {
var config *rest.Config
// Check if the kubeConfig file exists.
@@ -291,6 +291,7 @@ func newClient(configPath string, qps, burst int32) (*kubernetes.Clientset, erro
}
} else {
// Set to in-cluster config.
+ log.G(ctx).Infof("configPath: %q is not exist, it will run as in-cluster.", configPath)
config, err = rest.InClusterConfig()
if err != nil {
return nil, errors.Wrap(err, "error building in cluster config")