Skip to content

Commit a3467ac

Browse files
committed
feat: add support to read config from KUBECONFIG
1 parent 1216162 commit a3467ac

File tree

1 file changed

+6
-4
lines changed

1 file changed

+6
-4
lines changed

pkg/data_collector/data_collector.go

Lines changed: 6 additions & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -35,12 +35,14 @@ func NewDataCollector(namespaces ...string) (*DataCollector, error) {
3535
}
3636

3737
// Find config
38-
home := homedir.HomeDir()
39-
kubeConfig := filepath.Join(home, ".kube", "config")
38+
kubeConfig := os.Getenv("KUBECONFIG")
39+
if kubeConfig == "" {
40+
kubeConfig = filepath.Join(homedir.HomeDir(), ".kube", "config")
41+
}
4042
config, err := clientcmd.BuildConfigFromFlags("", kubeConfig)
4143

4244
if err != nil {
43-
return nil, fmt.Errorf("unable to create k8s config: %s", err)
45+
return nil, fmt.Errorf("unable to connect to k8s using file %s: %s", kubeConfig, err)
4446
}
4547

4648
dc := DataCollector{
@@ -71,7 +73,7 @@ func (c *DataCollector) WrapUp() (string, error) {
7173

7274
file, err := os.Create(tarballName)
7375
if err != nil {
74-
return "",err
76+
return "", err
7577
}
7678
defer file.Close()
7779

0 commit comments

Comments
 (0)