in pkg/k8s/k8s.go [31:46]
func ClientOrDie(kubeconfig string) *kubernetes.Clientset {
// try in-cluster config, and then default to kubeconfig
kConfig, err := rest.InClusterConfig()
if err != nil {
// use the current context in kubeconfig
kConfig, err = clientcmd.BuildConfigFromFlags("", kubeconfig)
if err != nil {
panic(err.Error())
}
}
clientset, err := kubernetes.NewForConfig(kConfig)
if err != nil {
panic(err.Error())
}
return clientset
}