added all

Signed-off-by: Emruz Hossain <emruz@appscode.com>

Author: Emruz Hossain

go.mod

@@ -16,7 +16,7 @@ require (
 	kmodules.xyz/client-go v0.0.0-20220203031013-1de48437aaf3
 	kmodules.xyz/custom-resources v0.0.0-20220208103158-61b298634e43
 	kmodules.xyz/offshoot-api v0.0.0-20211207130839-cc7187e020cf
-	stash.appscode.dev/apimachinery v0.18.0
+	stash.appscode.dev/apimachinery v0.18.1-0.20220308093046-7df8eca4f066
 )
 
 replace bitbucket.org/ww/goautoneg => gomodules.xyz/goautoneg v0.0.0-20120707110453-a547fc61f48d

go.sum

@@ -1108,5 +1108,5 @@ sigs.k8s.io/yaml v1.1.0/go.mod h1:UJmg0vDUVViEyp3mgSv9WPwZCDxu4rQW1olrI1uml+o=
 sigs.k8s.io/yaml v1.2.0 h1:kr/MCeFWJWTwyaHoR9c8EjH9OumOmoF9YGiZd7lFm/Q=
 sigs.k8s.io/yaml v1.2.0/go.mod h1:yfXDCHCao9+ENCvLSE62v9VSji2MKu5jeNfTrofGhJc=
 sourcegraph.com/sourcegraph/appdash v0.0.0-20190731080439-ebfcffb1b5c0/go.mod h1:hI742Nqp5OhwiqlzhgfbWU4mW4yO10fP+LoT9WOswdU=
-stash.appscode.dev/apimachinery v0.18.0 h1:Mo5m3ffLKePJMPVWufGlFXas3rAwu96R9BeswSNkTrI=
-stash.appscode.dev/apimachinery v0.18.0/go.mod h1:MDzqJ66A2QZKAHRksfHT5crOD29a0S5Hfuy/D5hHAjw=
+stash.appscode.dev/apimachinery v0.18.1-0.20220308093046-7df8eca4f066 h1:DFARQYwC8YnSCWlQ0MgBNgPDZFkr4c/zKbmdchIRfWo=
+stash.appscode.dev/apimachinery v0.18.1-0.20220308093046-7df8eca4f066/go.mod h1:R+AE9wyi0sPZ0t3HWwZq+FiA7ewoGbqsdW6atczGf94=

pkg/backup.go

@@ -18,7 +18,7 @@ package pkg
 
 import (
 	"context"
-	"fmt"
+	v1 "kmodules.xyz/offshoot-api/api/v1"
 	"path/filepath"
 	"time"
 
@@ -34,9 +34,9 @@ import (
 	"k8s.io/client-go/kubernetes"
 	"k8s.io/client-go/tools/clientcmd"
 	"k8s.io/klog/v2"
+	"kmodules.xyz/client-go/tools/backup"
 	appcatalog "kmodules.xyz/custom-resources/apis/appcatalog/v1alpha1"
 	appcatalog_cs "kmodules.xyz/custom-resources/client/clientset/versioned"
-	v1 "kmodules.xyz/offshoot-api/api/v1"
 )
 
 func NewCmdBackup() *cobra.Command {
@@ -68,6 +68,8 @@ func NewCmdBackup() *cobra.Command {
 			if err != nil {
 				return err
 			}
+			opt.config = config
+
 			err = license.CheckLicenseEndpoint(config, licenseApiService, SupportedProducts)
 			if err != nil {
 				return err
@@ -191,45 +193,21 @@ func (opt *esOptions) backupElasticsearch(targetRef api_v1beta1.TargetRef) (*res
 		return nil, err
 	}
 
-	// clear directory before running multielasticdump
-	session := opt.newSessionWrapper(MultiElasticDumpCMD)
+	klog.Infoln("ClientConfig: ", appBinding.Spec.ClientConfig)
 
-	err = opt.setDatabaseCredentials(appBinding, session.cmd)
-	if err != nil {
-		return nil, err
-	}
 	klog.Infoln("Cleaning up directory: ", opt.interimDataDir)
 	if err := clearDir(opt.interimDataDir); err != nil {
 		return nil, err
 	}
 
-	url, err := appBinding.URL()
-	if err != nil {
-		return nil, err
-	}
-	session.cmd.Args = append(session.cmd.Args, []interface{}{
-		fmt.Sprintf(`--input=%v`, url),
-		fmt.Sprintf(`--output=%v`, opt.interimDataDir),
-	}...)
+	// backup cluster resources yaml into opt.backupDir
+	mgr := backup.NewBackupManager(opt.context, opt.config, opt.sanitize)
 
-	err = session.setTLSParameters(appBinding, opt.setupOptions.ScratchDir)
+	_, err = mgr.BackupToDir(opt.interimDataDir)
 	if err != nil {
 		return nil, err
 	}
 
-	err = opt.waitForDBReady(appBinding)
-	if err != nil {
-		return nil, err
-	}
-
-	session.sh.ShowCMD = false
-	session.setUserArgs(opt.esArgs)
-	session.sh.Command(session.cmd.Name, session.cmd.Args...) // xref: multielasticdump: https://github.com/taskrabbit/elasticsearch-dump#multielasticdump
-
-	if err := session.sh.Run(); err != nil {
-		return nil, err
-	}
-
 	// dumped data has been stored in the interim data dir. Now, we will backup this directory using Stash.
 	opt.backupOptions.BackupPaths = []string{opt.interimDataDir}
 

pkg/restore.go

@@ -42,7 +42,6 @@ func NewRootCmd() *cobra.Command {
 
 	rootCmd.AddCommand(v.NewCmdVersion())
 	rootCmd.AddCommand(NewCmdBackup())
-	rootCmd.AddCommand(NewCmdRestore())
 
 	return rootCmd
 }

pkg/root.go

@@ -20,6 +20,7 @@ import (
 	"context"
 	"fmt"
 	"io/ioutil"
+	"k8s.io/client-go/rest"
 	"os"
 	"os/exec"
 	"path/filepath"
@@ -62,6 +63,10 @@ type esOptions struct {
 	storageSecret     kmapi.ObjectReference
 	waitTimeout       int32
 
+	sanitize bool
+	config   *rest.Config
+	context  string
+
 	setupOptions   restic.SetupOptions
 	backupOptions  restic.BackupOptions
 	restoreOptions restic.RestoreOptions

pkg/utils.go

@@ -0,0 +1,21 @@
+package arrays
+
+import (
+	"errors"
+	"reflect"
+)
+
+func InterfaceToSlice(slice interface{}) ([]interface{}, error) {
+	s := reflect.ValueOf(slice)
+	if s.Kind() != reflect.Slice {
+		return nil, errors.New("slice of interface not found")
+	}
+
+	ret := make([]interface{}, s.Len())
+
+	for i := 0; i < s.Len(); i++ {
+		ret[i] = s.Index(i).Interface()
+	}
+
+	return ret, nil
+}