add implement of globalnode

Signed-off-by: duanmengkk <[email protected]>

deploy/crds/kosmos.io_globalnodes.yaml

@@ -0,0 +1,93 @@
+---
+apiVersion: apiextensions.k8s.io/v1
+kind: CustomResourceDefinition
+metadata:
+  annotations:
+    controller-gen.kubebuilder.io/version: v0.11.0
+  creationTimestamp: null
+  name: globalnodes.kosmos.io
+spec:
+  group: kosmos.io
+  names:
+    kind: GlobalNode
+    listKind: GlobalNodeList
+    plural: globalnodes
+    singular: globalnode
+  scope: Cluster
+  versions:
+  - name: v1alpha1
+    schema:
+      openAPIV3Schema:
+        properties:
+          apiVersion:
+            description: 'APIVersion defines the versioned schema of this representation
+              of an object. Servers should convert recognized schemas to the latest
+              internal value, and may reject unrecognized values. More info: https://git.k8s.io/community/contributors/devel/sig-architecture/api-conventions.md#resources'
+            type: string
+          kind:
+            description: 'Kind is a string value representing the REST resource this
+              object represents. Servers may infer this from the endpoint the client
+              submits requests to. Cannot be updated. In CamelCase. More info: https://git.k8s.io/community/contributors/devel/sig-architecture/api-conventions.md#types-kinds'
+            type: string
+          metadata:
+            type: object
+          spec:
+            description: Spec is the specification for the behaviour of the GlobalNodeSpec.
+            properties:
+              labels:
+                additionalProperties:
+                  type: string
+                description: Set is a map of label:value. It implements Labels.
+                type: object
+              nodeIP:
+                type: string
+              state:
+                default: free
+                type: string
+            type: object
+          status:
+            properties:
+              conditions:
+                description: 'Conditions is an array of current observed node conditions.
+                  More info: https://kubernetes.io/docs/concepts/nodes/node/#condition'
+                items:
+                  description: NodeCondition contains condition information for a
+                    node.
+                  properties:
+                    lastHeartbeatTime:
+                      description: Last time we got an update on a given condition.
+                      format: date-time
+                      type: string
+                    lastTransitionTime:
+                      description: Last time the condition transit from one status
+                        to another.
+                      format: date-time
+                      type: string
+                    message:
+                      description: Human readable message indicating details about
+                        last transition.
+                      type: string
+                    reason:
+                      description: (brief) reason for the condition's last transition.
+                      type: string
+                    status:
+                      description: Status of the condition, one of True, False, Unknown.
+                      type: string
+                    type:
+                      description: Type of node condition.
+                      type: string
+                  required:
+                  - status
+                  - type
+                  type: object
+                type: array
+              virtualCluster:
+                type: string
+            type: object
+        required:
+        - spec
+        type: object
+    served: true
+    storage: true
+    subresources:
+      status: {}

deploy/crds/kosmos.io_virtualclusters.yaml

@@ -105,6 +105,8 @@ spec:
                         the kubernetes's control plane
                       format: int32
                       type: integer
+                  required:
+                  - nodeCount
                   type: object
                 type: array
               promoteResources:

global_node.yaml

@@ -0,0 +1,9 @@
+apiVersion: kosmos.io/v1alpha1
+kind: GlobalNode
+metadata:
+  name: example-globalnode
+spec:
+  nodeIP: "12.7"
+  labels: # Optional: fill in key-value pairs as needed
+    exampleKey: "exampleValue"
+

hack/generate_globalnode.sh

@@ -0,0 +1,30 @@
+#!/bin/bash
+
+# 确保提供了kubeconfig路径
+if [ -z "$KUBECONFIG" ]; then
+    echo "KUBECONFIG环境变量未设置."
+    exit 1
+fi
+
+# 获取所有node的名称
+nodes=$(kubectl get nodes -o jsonpath='{.items[*].metadata.name}')
+# 遍历所有node
+for node in ${nodes}; do
+    # 获取node的IP地址
+    nodeIP=$(kubectl get node ${node} -o jsonpath='{.status.addresses[0].address}')
+    # 获取node的标签，并转换为GlobalNode需要的格式
+    labels=$(kubectl get node ${node} -o jsonpath='{.metadata.labels}')
+    labelsFormatted=$(echo "$labels" | jq -r 'to_entries | .[] | "  \(.key): \(.value)"')
+    # 使用echo和管道将YAML直接传递给kubectl apply -f -
+    echo "
+apiVersion: kosmos.io/v1alpha1
+kind: GlobalNode
+metadata:
+  name: ${node}-globalnode
+spec:
+  nodeIP: \"${nodeIP}\"
+  labels:
+$(echo "${labelsFormatted}" | sed 's/=/": "/g' | awk '{print "    " $0}')
+" | kubectl apply -f -
+
+done

pkg/apis/kosmos/v1alpha1/clusterpodconvertpolicy_types.go

@@ -28,7 +28,7 @@ type ClusterPodConvertPolicySpec struct {
 
 	// A label query over a set of resources.
 	// If name is not empty, LeafNodeSelector will be ignored.
-	// +option
+	// +optional
 	LeafNodeSelector *metav1.LabelSelector `json:"leafNodeSelector,omitempty"`
 
 	// Converters are some converter for convert pod when pod synced from root cluster to leaf cluster

pkg/apis/kosmos/v1alpha1/global_node_types.go

@@ -0,0 +1,63 @@
+package v1alpha1
+
+import (
+	corev1 "k8s.io/api/core/v1"
+	metav1 "k8s.io/apimachinery/pkg/apis/meta/v1"
+	"k8s.io/apimachinery/pkg/labels"
+)
+
+// +genclient
+// +genclient:nonNamespaced
+// +kubebuilder:resource:scope="Cluster"
+// +kubebuilder:subresource:status
+// +k8s:deepcopy-gen:interfaces=k8s.io/apimachinery/pkg/runtime.Object
+
+type GlobalNode struct {
+	metav1.TypeMeta   `json:",inline"`
+	metav1.ObjectMeta `json:"metadata,omitempty"`
+
+	// Spec is the specification for the behaviour of the GlobalNodeSpec.
+	// +required
+	Spec GlobalNodeSpec `json:"spec"`
+
+	// +optional
+	Status GlobalNodeStatus `json:"status,omitempty"`
+}
+
+type GlobalNodeSpec struct {
+	// +optional
+	NodeIP string `json:"nodeIP,omitempty"`
+
+	// +kubebuilder:default=free
+	// +optional
+	State NodeState `json:"state,omitempty"`
+
+	// +optional
+	Labels labels.Set `json:"labels,omitempty"`
+}
+
+type NodeState string
+
+const (
+	NodeInUse     NodeState = "occupied"
+	NodeFreeState NodeState = "free"
+	NodeReserved  NodeState = "reserved"
+)
+
+type GlobalNodeStatus struct {
+	// +optional
+	VirtualCluster string `json:"virtualCluster,omitempty"`
+
+	// Conditions is an array of current observed node conditions.
+	// More info: https://kubernetes.io/docs/concepts/nodes/node/#condition
+	// +optional
+	Conditions []corev1.NodeCondition `json:"conditions,omitempty"`
+}
+
+// +k8s:deepcopy-gen:interfaces=k8s.io/apimachinery/pkg/runtime.Object
+
+type GlobalNodeList struct {
+	metav1.TypeMeta `json:",inline"`
+	metav1.ListMeta `json:"metadata"`
+	Items           []GlobalNode `json:"items"`
+}

pkg/apis/kosmos/v1alpha1/virtualcluster_types.go

@@ -50,7 +50,7 @@ type VirtualClusterSpec struct {
 	ExternalIP string `json:"externalIP,omitempty"`
 
 	// PromotePolicies definites the policies for promote to the kubernetes's control plane
-	// +optional
+	// +required
 	PromotePolicies []PromotePolicy `json:"promotePolicies,omitempty"`
 
 	// PromoteResources definites the resources for promote to the kubernetes's control plane,
@@ -65,8 +65,8 @@ type PromotePolicy struct {
 	LabelSelector *metav1.LabelSelector `json:"labelSelector,omitempty"`
 
 	// NodeCount is the number of nodes to promote to the kubernetes's control plane
-	// +optional
-	NodeCount *int32 `json:"nodeCount,omitempty"`
+	// +required
+	NodeCount int32 `json:"nodeCount"`
 }
 
 type PromoteResources struct {