Add work status controller framework (#75)

cmd/controller-manager/app/controllermanager.go

@@ -21,6 +21,7 @@ import (
 	"github.com/karmada-io/karmada/pkg/controllers/execution"
 	"github.com/karmada-io/karmada/pkg/controllers/membercluster"
 	"github.com/karmada-io/karmada/pkg/controllers/policy"
+	"github.com/karmada-io/karmada/pkg/controllers/status"
 	karmadaclientset "github.com/karmada-io/karmada/pkg/generated/clientset/versioned"
 )
 
@@ -131,4 +132,14 @@ func setupControllers(mgr controllerruntime.Manager) {
 	if err := executionController.SetupWithManager(mgr); err != nil {
 		klog.Fatalf("Failed to setup execution controller: %v", err)
 	}
+
+	workStatusController := &status.PropagationWorkStatusController{
+		Client:        mgr.GetClient(),
+		DynamicClient: dynamicClientSet,
+		EventRecorder: mgr.GetEventRecorderFor(status.WorkStatusControllerName),
+		RESTMapper:    mgr.GetRESTMapper(),
+	}
+	if err := workStatusController.SetupWithManager(mgr); err != nil {
+		klog.Fatalf("Failed to setup work status controller: %v", err)
+	}
 }

pkg/controllers/status/workstatus_controller.go

@@ -0,0 +1,54 @@
+package status
+
+import (
+	"context"
+
+	"k8s.io/apimachinery/pkg/api/errors"
+	"k8s.io/apimachinery/pkg/api/meta"
+	"k8s.io/client-go/dynamic"
+	"k8s.io/client-go/tools/record"
+	"k8s.io/klog/v2"
+	controllerruntime "sigs.k8s.io/controller-runtime"
+	"sigs.k8s.io/controller-runtime/pkg/client"
+
+	"github.com/karmada-io/karmada/pkg/apis/propagationstrategy/v1alpha1"
+)
+
+// WorkStatusControllerName is the controller name that will be used when reporting events.
+const WorkStatusControllerName = "work-status-controller"
+
+// PropagationWorkStatusController is to sync status of PropagationWork.
+type PropagationWorkStatusController struct {
+	client.Client                   // used to operate PropagationWork resources.
+	DynamicClient dynamic.Interface // used to fetch arbitrary resources.
+	EventRecorder record.EventRecorder
+	RESTMapper    meta.RESTMapper
+}
+
+// Reconcile performs a full reconciliation for the object referred to by the Request.
+// The Controller will requeue the Request to be processed again if an error is non-nil or
+// Result.Requeue is true, otherwise upon completion it will remove the work from the queue.
+func (c *PropagationWorkStatusController) Reconcile(req controllerruntime.Request) (controllerruntime.Result, error) {
+	klog.V(4).Infof("Reconciling status of PropagationWork %s.", req.NamespacedName.String())
+
+	work := &v1alpha1.PropagationWork{}
+	if err := c.Client.Get(context.TODO(), req.NamespacedName, work); err != nil {
+		// The resource may no longer exist, in which case we stop processing.
+		if errors.IsNotFound(err) {
+			return controllerruntime.Result{}, nil
+		}
+
+		return controllerruntime.Result{Requeue: true}, err
+	}
+
+	if !work.DeletionTimestamp.IsZero() {
+		return controllerruntime.Result{}, nil
+	}
+
+	return controllerruntime.Result{}, nil
+}
+
+// SetupWithManager creates a controller and register to controller manager.
+func (c *PropagationWorkStatusController) SetupWithManager(mgr controllerruntime.Manager) error {
+	return controllerruntime.NewControllerManagedBy(mgr).For(&v1alpha1.PropagationWork{}).Complete(c)
+}