feat: support skip syncing matrixonecluster cr (#562)

matrixorigin · Oct 24, 2024 · 124d07b · 124d07b
1 parent 813ff0f
commit 124d07b
Showing 1 changed file with 9 additions and 0 deletions.
diff --git a/pkg/controllers/mocluster/controller.go b/pkg/controllers/mocluster/controller.go
@@ -40,6 +40,7 @@ import (
 
 const (
 	RestoreCompleteAnno = "matrixorigin.io/restore-complete"
+	annSkipSync         = "matrixorigin.io/skip-sync"
 )
 
 const (
@@ -60,6 +61,10 @@ var _ recon.Actor[*v1alpha1.MatrixOneCluster] = &MatrixOneClusterActor{}
 type MatrixOneClusterActor struct{}
 
 func (r *MatrixOneClusterActor) Observe(ctx *recon.Context[*v1alpha1.MatrixOneCluster]) (recon.Action[*v1alpha1.MatrixOneCluster], error) {
+	if ctx.Obj.Annotations[annSkipSync] != "" {
+		ctx.Log.Info(fmt.Sprintf("skip sync matrixonecluster %v", client.ObjectKeyFromObject(ctx.Obj)))
+		return nil, nil
+	}
 	mo := ctx.Obj
 	if mo.Spec.RestoreFrom != nil && mo.Annotations[RestoreCompleteAnno] == "" {
 		// do restore
@@ -473,6 +478,10 @@ func syncedCondition(mo *v1alpha1.MatrixOneCluster) metav1.Condition {
 }
 
 func (r *MatrixOneClusterActor) Finalize(ctx *recon.Context[*v1alpha1.MatrixOneCluster]) (bool, error) {
+	if ctx.Obj.Annotations[annSkipSync] != "" {
+		ctx.Log.Info(fmt.Sprintf("skip finalize matrixonecluster %v", client.ObjectKeyFromObject(ctx.Obj)))
+		return true, nil
+	}
 	mo := ctx.Obj
 	err := ctx.Client.DeleteAllOf(ctx, &v1alpha1.CNSet{}, client.InNamespace(mo.Namespace), client.MatchingLabels(
 		map[string]string{common.MatrixoneClusterLabelKey: mo.Name},