Cleanup code

This commit is contained in:
Jean-Marc ANDRE 2020-11-25 22:55:05 +01:00
parent 19defd05e4
commit 08bfb6aad6

View File

@ -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())
}