enable mcs to support headless-svc

karmada-io · Apr 7, 2023 · c98ec5f · c98ec5f
1 parent b7a4fb0
commit c98ec5f
Showing 1 changed file with 5 additions and 1 deletion.
diff --git a/pkg/controllers/mcs/service_import_controller.go b/pkg/controllers/mcs/service_import_controller.go
@@ -40,7 +40,7 @@ func (c *ServiceImportController) Reconcile(ctx context.Context, req controllerr
 		return controllerruntime.Result{Requeue: true}, err
 	}
 
-	if !svcImport.DeletionTimestamp.IsZero() || svcImport.Spec.Type != mcsv1alpha1.ClusterSetIP {
+	if !svcImport.DeletionTimestamp.IsZero() {
 		return controllerruntime.Result{}, nil
 	}
 
@@ -93,6 +93,10 @@ func (c *ServiceImportController) deriveServiceFromServiceImport(svcImport *mcsv
 		},
 	}
 
+	if svcImport.Spec.Type == mcsv1alpha1.Headless {
+		newDerivedService.Spec.ClusterIP = corev1.ClusterIPNone
+	}
+
 	oldDerivedService := &corev1.Service{}
 	err := c.Client.Get(context.TODO(), types.NamespacedName{
 		Name:      names.GenerateDerivedServiceName(svcImport.Name),