diff --git a/src/create/root.go b/src/create/root.go index ba852f5..c4a451a 100644 --- a/src/create/root.go +++ b/src/create/root.go @@ -10,7 +10,6 @@ import ( "path/filepath" metav1 "k8s.io/apimachinery/pkg/apis/meta/v1" "k8s.io/apimachinery/pkg/runtime" - "k8s.io/client-go/kubernetes" clientgoscheme "k8s.io/client-go/kubernetes/scheme" "k8s.io/client-go/rest" "k8s.io/client-go/tools/clientcmd" @@ -31,19 +30,7 @@ func CreateBackupSession(name string, namespace string) { _ = formolv1alpha1.AddToScheme(scheme) _ = clientgoscheme.AddToScheme(scheme) cl, err := client.New(config, client.Options{Scheme: scheme}) - if err != nil { - panic(err.Error()) - } - clientset, err := kubernetes.NewForConfig(config) - if err != nil { - panic(err.Error()) - } - pods, err := clientset.CoreV1().Pods("").List(context.TODO(), metav1.ListOptions{}) - if err != nil { - panic(err.Error()) - } - fmt.Printf("There are %d pods in the cluster\n", len(pods.Items)) backupSession := &formolv1alpha1.BackupSession{ ObjectMeta: metav1.ObjectMeta{ Name: strings.Join([]string{"backupsession",name,strconv.FormatInt(time.Now().Unix(), 10)}, "-"), @@ -57,6 +44,9 @@ func CreateBackupSession(name string, namespace string) { }, Status: formolv1alpha1.BackupSessionStatus{}, } + if err != nil { + panic(err.Error()) + } if err := cl.Create(context.TODO(), backupSession); err != nil { panic(err.Error()) }