feat: List&watch mcs and service, reconcile the work in execution namespace

cmd/controller-manager/app/controllermanager.go

@@ -63,6 +63,7 @@ import (
 	"github.com/karmada-io/karmada/pkg/controllers/gracefuleviction"
 	"github.com/karmada-io/karmada/pkg/controllers/hpareplicassyncer"
 	"github.com/karmada-io/karmada/pkg/controllers/mcs"
+	"github.com/karmada-io/karmada/pkg/controllers/multiclusterservice"
 	"github.com/karmada-io/karmada/pkg/controllers/namespace"
 	"github.com/karmada-io/karmada/pkg/controllers/status"
 	"github.com/karmada-io/karmada/pkg/controllers/unifiedauth"
@@ -224,6 +225,7 @@ func init() {
 	controllers["federatedHorizontalPodAutoscaler"] = startFederatedHorizontalPodAutoscalerController
 	controllers["cronFederatedHorizontalPodAutoscaler"] = startCronFederatedHorizontalPodAutoscalerController
 	controllers["hpaReplicasSyncer"] = startHPAReplicasSyncerController
+	controllers["multiclusterservice"] = startMCSController
 }
 
 func startClusterController(ctx controllerscontext.Context) (enabled bool, err error) {
@@ -631,6 +633,18 @@ func startHPAReplicasSyncerController(ctx controllerscontext.Context) (enabled b
 	return true, nil
 }
 
+func startMCSController(ctx controllerscontext.Context) (enabled bool, err error) {
+	mcsController := &multiclusterservice.MCSController{
+		Client:             ctx.Mgr.GetClient(),
+		EventRecorder:      ctx.Mgr.GetEventRecorderFor(multiclusterservice.ControllerName),
+		RateLimiterOptions: ctx.Opts.RateLimiterOptions,
+	}
+	if err = mcsController.SetupWithManager(ctx.Mgr); err != nil {
+		return false, err
+	}
+	return true, nil
+}
+
 // setupControllers initialize controllers and setup one by one.
 func setupControllers(mgr controllerruntime.Manager, opts *options.Options, stopChan <-chan struct{}) {
 	restConfig := mgr.GetConfig()

pkg/apis/networking/v1alpha1/service_types.go

@@ -30,6 +30,8 @@ const (
 	ResourcePluralMultiClusterService = "multiclusterservices"
 	// ResourceNamespaceScopedMultiClusterService indicates if MultiClusterService is NamespaceScoped.
 	ResourceNamespaceScopedMultiClusterService = true
+	// MCSServiceAppliedConditionType is indicates the condition type of mcs service applied.
+	MCSServiceAppliedConditionType = "ServiceApplied"
 )
 
 // +genclient

pkg/apis/networking/v1alpha1/well_known_constants.go

@@ -0,0 +1,23 @@
+/*
+Copyright 2023 The Karmada Authors.
+Licensed under the Apache License, Version 2.0 (the "License");
+you may not use this file except in compliance with the License.
+You may obtain a copy of the License at
+    http://www.apache.org/licenses/LICENSE-2.0
+Unless required by applicable law or agreed to in writing, software
+distributed under the License is distributed on an "AS IS" BASIS,
+WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+See the License for the specific language governing permissions and
+limitations under the License.
+*/
+
+package v1alpha1
+
+const (
+	// MultiClusterServicePermanentIDLabel is the identifier of a MultiClusterService object.
+	// Karmada generates a unique identifier, such as metadata.UUID, for each MultiClusterService object.
+	// This identifier will be used as a label selector to locate corresponding work of service.
+	// The reason for generating a new unique identifier instead of simply using metadata.UUID is because:
+	// In backup scenarios, when applying the backup resource manifest in a new cluster, the UUID may change.
+	MultiClusterServicePermanentIDLabel = "multiclusterservice.karmada.io/permanent-id"
+)