Supports token authentication with kubernets

Issue-Id: OOM-379
Change-Id: If5457672f29f2567a6773d96985b62ad8cef5d0c
Signed-off-by: HuabingZhao <zhao.huabing@zte.com.cn>

diff --git a/src/kube2msb/kube2msb.go b/src/kube2msb/kube2msb.go
index 627405e..2d39b77 100644 (file)
--- a/src/kube2msb/kube2msb.go
+++ b/src/kube2msb/kube2msb.go
@@ -92,6 +92,11 @@ func newKubeClient() (*kclient.Client, error) {
        overrides := &kclientcmd.ConfigOverrides{}
        overrides.ClusterInfo.Server = masterUrl
 
+       if token, present := os.LookupEnv("AUTH_TOKEN"); present {
+               overrides.AuthInfo.Token = token
+               overrides.ClusterInfo.InsecureSkipTLSVerify = true
+       }
+
        rules := kclientcmd.NewDefaultClientConfigLoadingRules()
        kubeConfig, err := kclientcmd.NewNonInteractiveDeferredLoadingClientConfig(rules, overrides).ClientConfig()