feat: create convert-related crds when join cluster

Signed-off-by: ONE7live <[email protected]>
kosmos-io · May 11, 2024 · 7d618e7 · 7d618e7
1 parent a4f3927
commit 7d618e7
Show file tree

Hide file tree

Showing 3 changed files with 2,843 additions and 1 deletion.
diff --git a/deploy/crds/kosmos.io_clusterpodconvertpolicies.yaml b/deploy/crds/kosmos.io_clusterpodconvertpolicies.yaml
@@ -15,7 +15,7 @@ spec:
     shortNames:
       - cpcp
     singular: clusterpodconvertpolicy
-  scope: Namespaced
+  scope: Cluster
   versions:
     - name: v1alpha1
       schema:

diff --git a/pkg/kosmosctl/join/join.go b/pkg/kosmosctl/join/join.go
@@ -339,6 +339,30 @@ func (o *CommandJoinOptions) runCluster() error {
 			return err
 		}
 
+		clusterPodConvert, err := util.GenerateCustomResourceDefinition(manifest.ClusterPodConvert, nil)
+		if err != nil {
+			return err
+		}
+		_, err = o.K8sExtensionsClient.ApiextensionsV1().CustomResourceDefinitions().Create(context.Background(), clusterPodConvert, metav1.CreateOptions{})
+		if err != nil {
+			if !apierrors.IsAlreadyExists(err) {
+				return fmt.Errorf("kosmosctl join run error, crd options failed: %v", err)
+			}
+		}
+		klog.Info("Create CRD " + clusterPodConvert.Name + " successful.")
+
+		podConvert, err := util.GenerateCustomResourceDefinition(manifest.PodConvert, nil)
+		if err != nil {
+			return err
+		}
+		_, err = o.K8sExtensionsClient.ApiextensionsV1().CustomResourceDefinitions().Create(context.Background(), podConvert, metav1.CreateOptions{})
+		if err != nil {
+			if !apierrors.IsAlreadyExists(err) {
+				return fmt.Errorf("kosmosctl join run error, crd options failed: %v", err)
+			}
+		}
+		klog.Info("Create CRD " + podConvert.Name + " successful.")
+
 		if len(o.LeafModel) > 0 {
 			switch o.LeafModel {
 			case "one-to-one":