🐛 Fix webhook issue when there are multiple replication of controller

virtualcluster/cmd/manager/main.go

@@ -140,11 +140,12 @@ func main() {
 	}
 
 	if enableWebhook == true {
-		log.Info("setting up webhooks")
-		if err := webhook.AddToManager(mgr, mgrOpt.CertDir); err != nil {
-			log.Error(err, "unable to register webhooks to the manager")
-			os.Exit(1)
+		webhookHandler := &webhook.WebhookHandler{
+			Manager: mgr,
+			CertDir: mgrOpt.CertDir,
 		}
+
+		mgr.Add(webhookHandler)
 	}
 
 	// Start the Cmd

virtualcluster/pkg/webhook/webhook.go

@@ -17,17 +17,33 @@ limitations under the License.
 package webhook
 
 import (
+	"context"
+
 	"sigs.k8s.io/controller-runtime/pkg/manager"
 )
 
 // AddToManagerFuncs is a list of functions to add all Controllers to the Manager
 var AddToManagerFuncs []func(manager.Manager, string) error
 
+type WebhookHandler struct {
+	Manager manager.Manager
+	CertDir string
+}
+
+func (wh *WebhookHandler) Start(context context.Context) error {
+	addToManager(wh.Manager, wh.CertDir)
+	return nil
+}
+
+func (wh *WebhookHandler) NeedLeaderElection() bool {
+	return true
+}
+
 // AddToManager adds all Controllers to the Manager
 // +kubebuilder:rbac:groups=admissionregistration.k8s.io,resources=mutatingwebhookconfigurations;validatingwebhookconfigurations,verbs=get;list;watch;create;update;patch;delete
 // +kubebuilder:rbac:groups="",resources=secrets,verbs=get;list;watch;create;update;patch;delete
 // +kubebuilder:rbac:groups="",resources=services,verbs=get;list;watch;create;update;patch;delete
-func AddToManager(m manager.Manager, certDir string) error {
+func addToManager(m manager.Manager, certDir string) error {
 	for _, f := range AddToManagerFuncs {
 		if err := f(m, certDir); err != nil {
 			return err