func()

in pkg/k8s/k8s_client.go [109:130]

• 22 lines of code
• 6 McCabe index (conditional complexity)

func (kr *K8S) initInCluster() error {
	if kr.Client != nil {
		return nil
	}
	hostInClustser := os.Getenv("KUBERNETES_SERVICE_HOST")
	if hostInClustser == "" {
		return nil
	}
	config, err := rest.InClusterConfig()
	if err != nil {
		panic(err)
	}
	kr.Client, err = kubernetes.NewForConfig(config)
	if err != nil {
		return err
	}
	if Debug {
		log.Println("Using in-cluster k8s ", hostInClustser)
	}
	kr.Mesh.InCluster = true
	return nil
}