br: implement federation volume backup controller (#5013) (#5135)

Signed-off-by: WangLe1321 <[email protected]>
Co-authored-by: WangLe1321 <[email protected]>

Makefile

@@ -187,6 +187,9 @@ check: $(addprefix check-,$(ALL_CHECKS)) tidy
 check-%:
 	./hack/verify-$*.sh
 
+generate:
+	./hack/update-all.sh
+
 crd:
 	./hack/update-crd.sh
 

cmd/backup-manager/app/backup/backup.go

@@ -88,6 +88,7 @@ func (bo *Options) backupData(
 		// Currently, we only support aws ebs volume snapshot.
 		specificArgs = append(specificArgs, "--type=aws-ebs")
 		specificArgs = append(specificArgs, fmt.Sprintf("--volume-file=%s", localCSBFile))
+		specificArgs = append(specificArgs, "--operator-paused-gc-and-scheduler=true")
 		logCallback = func(line string) {
 			if strings.Contains(line, successTag) {
 				extract := strings.Split(line, successTag)[1]

cmd/br-federation-manager/main.go

@@ -218,13 +218,13 @@ func main() {
 	klog.Infof("br-federation-manager exited")
 }
 
-func initFederationKubeClients(cliCfg *controller.BrFedCLIConfig) (map[string]*fedversioned.Clientset, error) {
+func initFederationKubeClients(cliCfg *controller.BrFedCLIConfig) (map[string]fedversioned.Interface, error) {
 	files, err := os.ReadDir(cliCfg.FederationKubeConfigPath)
 	if err != nil {
 		return nil, err
 	}
 
-	clients := make(map[string]*fedversioned.Clientset)
+	clients := make(map[string]fedversioned.Interface)
 	for _, f := range files {
 		if f.IsDir() || f.Name() == "..data" {
 			continue