Enable binding controller

artifacts/deploy/clusterrole.yaml

@@ -14,3 +14,7 @@ rules:
     resources:
     - '*'
     verbs: ["get", "watch", "list", "create", "update", "delete"]
+  - apiGroups: ["propagationstrategy.karmada.io"]
+      resources:
+        - '*'
+      verbs: ["get", "watch", "list", "create", "update", "delete"]

artifacts/deploy/crd_binding.yaml

@@ -0,0 +1,28 @@
+---
+apiVersion: apiextensions.k8s.io/v1beta1
+kind: CustomResourceDefinition
+metadata:
+  annotations:
+    "helm.sh/hook": crd-install
+  creationTimestamp: null
+  name: propagationbindings.propagationstrategy.karmada.io
+spec:
+  group: propagationstrategy.karmada.io
+  names:
+    kind: PropagationBinding
+    listKind: PropagationBindingList
+    plural: propagationbindings
+    singular: propagationbinding
+  scope: Namespaced
+  version: v1alpha1
+  versions:
+    - name: v1alpha1
+      served: true
+      storage: true
+status:
+  acceptedNames:
+    kind: ""
+    plural: ""
+  conditions: []
+  storedVersions: []
+---

artifacts/deploy/crd_work.yaml

@@ -0,0 +1,28 @@
+---
+apiVersion: apiextensions.k8s.io/v1beta1
+kind: CustomResourceDefinition
+metadata:
+  annotations:
+    "helm.sh/hook": crd-install
+  creationTimestamp: null
+  name: propagationworks.propagationstrategy.karmada.io
+spec:
+  group: propagationstrategy.karmada.io
+  names:
+    kind: PropagationWork
+    listKind: PropagationWorkList
+    plural: propagationworks
+    singular: propagationwork
+  scope: Namespaced
+  version: v1alpha1
+  versions:
+    - name: v1alpha1
+      served: true
+      storage: true
+status:
+  acceptedNames:
+    kind: ""
+    plural: ""
+  conditions: []
+  storedVersions: []
+---

artifacts/example/binding.yaml

@@ -0,0 +1,10 @@
+apiVersion: propagationstrategy.karmada.io/v1alpha1
+kind: PropagationBinding
+metadata:
+  name: binding-foo
+spec:
+  resource:
+    apiVersion: apps/v1
+    kind: Deployment
+    name: nginx
+    namespace: default

cmd/controller-manager/app/controllermanager.go

@@ -17,6 +17,7 @@ import (
 	"github.com/huawei-cloudnative/karmada/cmd/controller-manager/app/leaderelection"
 	"github.com/huawei-cloudnative/karmada/cmd/controller-manager/app/options"
 	"github.com/huawei-cloudnative/karmada/pkg/controllers/membercluster"
+	"github.com/huawei-cloudnative/karmada/pkg/controllers/binding"
 	"github.com/huawei-cloudnative/karmada/pkg/controllers/util"
 )
 
@@ -104,4 +105,8 @@ func startControllers(opts *options.Options, stopChan <-chan struct{}) {
 	if err := membercluster.StartMemberClusterController(controllerConfig, stopChan); err != nil {
 		klog.Fatalf("Failed to start member cluster controller. error: %v", err)
 	}
+
+	if err := binding.StartPropagationBindingController(controllerConfig, stopChan); err != nil {
+		klog.Fatalf("Failed to start binding controller. error: %v", err)
+	}
 }

pkg/controllers/binding/binding_controller.go

@@ -34,6 +34,7 @@ type Controller struct {
 	// kubeClientSet is a standard kubernetes clientset.
 	kubeClientSet kubernetes.Interface
 
+	karmadaInformerFactory   informers.SharedInformerFactory
 	propagationBindingLister listers.PropagationBindingLister
 	propagationBindingSynced cache.InformerSynced
 	// workqueue is a rate limited work queue. This is used to queue work to be
@@ -72,8 +73,8 @@ func newPropagationBindingController(config *util.ControllerConfig) (*Controller
 	kubeClientSet := kubernetes.NewForConfigOrDie(headClusterConfig)
 
 	karmadaClientSet := clientset.NewForConfigOrDie(headClusterConfig)
-	propagationBindingInformer := informers.NewSharedInformerFactory(karmadaClientSet, 0).Propagationstrategy().V1alpha1().PropagationBindings()
-
+	karmadaInformerFactory := informers.NewSharedInformerFactory(karmadaClientSet, 0)
+	propagationBindingInformer := karmadaInformerFactory.Propagationstrategy().V1alpha1().PropagationBindings()
 	// Add karmada types to the default Kubernetes Scheme so Events can be logged for karmada types.
 	utilruntime.Must(karmadaScheme.AddToScheme(scheme.Scheme))
 
@@ -85,6 +86,7 @@ func newPropagationBindingController(config *util.ControllerConfig) (*Controller
 	controller := &Controller{
 		karmadaClientSet:         karmadaClientSet,
 		kubeClientSet:            kubeClientSet,
+		karmadaInformerFactory:   karmadaInformerFactory,
 		propagationBindingLister: propagationBindingInformer.Lister(),
 		propagationBindingSynced: propagationBindingInformer.Informer().HasSynced,
 		workqueue:                workqueue.NewNamedRateLimitingQueue(workqueue.DefaultControllerRateLimiter(), controllerAgentName),
@@ -117,7 +119,8 @@ func (c *Controller) Run(workerNumber int, stopCh <-chan struct{}) error {
 	defer utilruntime.HandleCrash()
 	defer c.workqueue.ShutDown()
 
-	klog.Infof("Starting controller: %s", controllerAgentName)
+	klog.Infof("Run controller: %s", controllerAgentName)
+	c.karmadaInformerFactory.Start(stopCh)
 
 	// Wait for the caches to be synced before starting workers
 	klog.Info("Waiting for informer caches to sync")
@@ -223,7 +226,7 @@ func (c *Controller) syncHandler(key string) error {
 
 		return err
 	}
-
+	klog.Infof("propagationBinding: %+v", propagationBinding)
 	klog.Infof("Sync propagationBinding: %s/%s", propagationBinding.Namespace, propagationBinding.Name)
 
 	return nil