我试图以编程方式获取Go,即〜/ .kube / config中当前上下文的命名空间。
到目前为止,我尝试的是这些模块:
"k8s.io/client-go/tools/clientcmd"
"k8s.io/client-go/kubernetes"
kubeconfig := filepath.Join(
os.Getenv("HOME"), ".kube", "config",
)
config, err := clientcmd.BuildConfigFromFlags("", kubeconfig)
if err != nil {
log.Fatal(err)
}
fmt.Printf("Namespace: %s\n", config.Namespace())
clientset, err := kubernetes.NewForConfig(config)
if err != nil {
log.Fatal(err)
}
但仍然没有线索,如果clientset可以给我我想要的命名空间。从这个线程:How to get current namespace of an in-cluster go Kubernetes client
它说了一些事情要做:kubeconfig.Namespace()
我找到了使用NewDefaultClientConfigLoadingRules
然后加载规则的解决方案。如果您的配置可以使用默认的客户端配置加载规则加载,则此方法有效。
例:
package main
import (
"github.com/davecgh/go-spew/spew"
"k8s.io/client-go/tools/clientcmd"
)
func main() {
clientCfg, err := clientcmd.NewDefaultClientConfigLoadingRules().Load()
spew.Dump(clientCfg, err)
}
给你一个包含当前上下文的https://godoc.org/k8s.io/client-go/tools/clientcmd/api#Config,包括它的命名空间。
Contexts: (map[string]*api.Context) (len=1) {
(string) (len=17) "xxx.xxxxx.xxx": (*api.Context)(0xc0001b2b40)({
LocationOfOrigin: (string) (len=30) "/path/to/.kube/config",
Cluster: (string) (len=17) "xxx.xxxxx.xxx",
AuthInfo: (string) (len=29) "[email protected]",
Namespace: (string) (len=7) "default",
Extensions: (map[string]runtime.Object) {
}
})
},
CurrentContext: (string) (len=17) "xxx.xxxxx.xxx",
为了您的信息,ClientConfigLoadingRules是一个具有不同属性的结构,用于告知cliclient从何处加载配置。默认值将使用Precedence字段中KUBECONFIG
环境变量中的路径。
(*clientcmd.ClientConfigLoadingRules)(0xc0000a31d0)({
ExplicitPath: (string) "",
Precedence: ([]string) (len=1 cap=1) {
(string) (len=30) "/path/to/.kube/config"
},
MigrationRules: (map[string]string) (len=1) {
(string) (len=30) "/path/to/.kube/config": (string) (len=35) "/path/to/.kube/.kubeconfig"
},
DoNotResolvePaths: (bool) false,
DefaultClientConfig: (clientcmd.ClientConfig) <nil>
})
import Required:
"k8s.io/client-go/tools/clientcmd"
loadingRules := clientcmd.NewDefaultClientConfigLoadingRules()
configOverrides := &clientcmd.ConfigOverrides{} kubeConfig :=
clientcmd.NewNonInteractiveDeferredLoadingClientConfig(loadingRules,
configOverrides)
namespace, _, err = kubeConfig.Namespace()