package k8sutil import ( "k8s.io/client-go/kubernetes" "k8s.io/client-go/rest" ) func GetK8sClient() (*kubernetes.Clientset, error) { config, err := rest.InClusterConfig() if err != nil { return nil, err } k8sClient, err := kubernetes.NewForConfig(config) if err != nil { return nil, err } return k8sClient, nil }