forked from vmware-tanzu/sonobuoy
-
Notifications
You must be signed in to change notification settings - Fork 0
/
kubeconfig.go
66 lines (52 loc) · 1.84 KB
/
kubeconfig.go
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
/*
Copyright 2018 Heptio Inc.
Licensed under the Apache License, Version 2.0 (the "License");
you may not use this file except in compliance with the License.
You may obtain a copy of the License at
http://www.apache.org/licenses/LICENSE-2.0
Unless required by applicable law or agreed to in writing, software
distributed under the License is distributed on an "AS IS" BASIS,
WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
See the License for the specific language governing permissions and
limitations under the License.
*/
package app
import (
"github.com/spf13/pflag"
"k8s.io/client-go/rest"
"k8s.io/client-go/tools/clientcmd"
// Add auth providers
_ "k8s.io/client-go/plugin/pkg/client/auth"
)
// Kubeconfig represents an explict or implict kubeconfig
type Kubeconfig struct {
*clientcmd.ClientConfigLoadingRules
}
// Make sure Kubeconfig implements Value properly
var _ pflag.Value = &Kubeconfig{}
// String needed for pflag.Value
func (c *Kubeconfig) String() string {
if c.ClientConfigLoadingRules != nil {
return c.ExplicitPath
}
return ""
}
// Type needed for pflag.Value
func (c *Kubeconfig) Type() string { return "Kubeconfig" }
// Set sets the explicit path of the loader to the provided config file
func (c *Kubeconfig) Set(str string) error {
if c.ClientConfigLoadingRules == nil {
c.ClientConfigLoadingRules = clientcmd.NewDefaultClientConfigLoadingRules()
}
c.ExplicitPath = str
return nil
}
// Get returns a rest Config, possibly based on a provided config
func (c *Kubeconfig) Get() (*rest.Config, error) {
if c.ClientConfigLoadingRules == nil {
c.ClientConfigLoadingRules = clientcmd.NewDefaultClientConfigLoadingRules()
}
configOverrides := &clientcmd.ConfigOverrides{}
kubeConfig := clientcmd.NewNonInteractiveDeferredLoadingClientConfig(c, configOverrides)
return kubeConfig.ClientConfig()
}