fix: hypervisor name mismatch and test case issue

Author: Code2Life

.vscode/launch.json

@@ -27,7 +27,7 @@
             "mode": "auto",
             "console": "integratedTerminal",
             "env": {
-                "KUBECONFIG": "~/.kube/config",
+                "KUBECONFIG": "~/.kube/config-local-studio",
                 "HYPERVISOR_PORT": "8042",
                 "GPU_NODE_NAME": "ubuntu",
             },
@@ -65,7 +65,8 @@
                 "ENABLE_WEBHOOKS": "false",
                 "ENABLE_SCHEDULER": "true",
                 "ENABLE_CR_CONTROLLER": "true",
-                "NVIDIA_OPERATOR_PROGRESSIVE_MIGRATION": "true"
+                "NVIDIA_OPERATOR_PROGRESSIVE_MIGRATION": "true",
+                "IMPERSONATE_SERVICE_ACCOUNT": "system:serviceaccount:tensor-fusion-sys:tensor-fusion-sys"
             },
             "args": [
                 "--metrics-path", "${workspaceFolder}/logs/metrics.log",

internal/component/hypervisor.go

@@ -88,7 +88,7 @@ func (h *Hypervisor) GetResourcesInfo(r client.Client, ctx context.Context, pool
 		}
 		key := client.ObjectKey{
 			Namespace: utils.CurrentNamespace(),
-			Name:      fmt.Sprintf("hypervisor-%s", node.Name),
+			Name:      fmt.Sprintf("tf-hypervisor-%s", node.Name),
 		}
 		pod := &corev1.Pod{}
 		err := r.Get(ctx, key, pod)

internal/controller/gpunode_controller_test.go

@@ -29,7 +29,7 @@ import (
 
 var _ = Describe("GPUNode Controller", func() {
 	Context("When reconciling gpunodes", func() {
-		It("should create the node discovery job and the hypervisor pod", func() {
+		It("should create the hypervisor pod", func() {
 			tfEnv := NewTensorFusionEnvBuilder().
 				AddPoolWithNodeCount(1).
 				SetGpuCountPerNode(1).
@@ -40,7 +40,7 @@ var _ = Describe("GPUNode Controller", func() {
 			pod := &corev1.Pod{}
 			Eventually(func(g Gomega) {
 				err := k8sClient.Get(ctx, types.NamespacedName{
-					Name:      fmt.Sprintf("hypervisor-%s", gpuNode.Name),
+					Name:      fmt.Sprintf("tf-hypervisor-%s", gpuNode.Name),
 					Namespace: utils.CurrentNamespace(),
 				}, pod)
 				g.Expect(err).ShouldNot(HaveOccurred())
@@ -59,7 +59,7 @@ var _ = Describe("GPUNode Controller", func() {
 			Eventually(func(g Gomega) {
 				newPod := &corev1.Pod{}
 				err := k8sClient.Get(ctx, types.NamespacedName{
-					Name:      fmt.Sprintf("hypervisor-%s", gpuNode.Name),
+					Name:      fmt.Sprintf("tf-hypervisor-%s", gpuNode.Name),
 					Namespace: utils.CurrentNamespace(),
 				}, newPod)
 				g.Expect(err).ShouldNot(HaveOccurred())

internal/controller/gpupool_controller_test.go

@@ -429,7 +429,7 @@ func verifyHypervisorPodHash(gpuNode *tfv1.GPUNode, hash string) {
 	Eventually(func(g Gomega) {
 		pod := &corev1.Pod{}
 		g.Expect(k8sClient.Get(ctx, client.ObjectKey{
-			Name:      fmt.Sprintf("hypervisor-%s", gpuNode.Name),
+			Name:      fmt.Sprintf("tf-hypervisor-%s", gpuNode.Name),
 			Namespace: utils.CurrentNamespace(),
 		}, pod)).Should(Succeed())
 		g.Expect(pod.Labels[constants.LabelKeyPodTemplateHash]).Should(Equal(hash))
@@ -463,7 +463,7 @@ func verifyHypervisorPodHashConsistently(gpuNode *tfv1.GPUNode, hash string) {
 	Consistently(func(g Gomega) {
 		pod := &corev1.Pod{}
 		g.Expect(k8sClient.Get(ctx, client.ObjectKey{
-			Name:      fmt.Sprintf("hypervisor-%s", gpuNode.Name),
+			Name:      fmt.Sprintf("tf-hypervisor-%s", gpuNode.Name),
 			Namespace: utils.CurrentNamespace(),
 		}, pod)).Should(Succeed())
 		g.Expect(pod.Labels[constants.LabelKeyPodTemplateHash]).Should(Equal(hash))
@@ -486,7 +486,7 @@ func verifyAllHypervisorPodHash(tfEnv *TensorFusionEnv, hash string) {
 		for _, gpuNode := range nodeList.Items {
 			pod := &corev1.Pod{}
 			g.Expect(k8sClient.Get(ctx, client.ObjectKey{
-				Name:      fmt.Sprintf("hypervisor-%s", gpuNode.Name),
+				Name:      fmt.Sprintf("tf-hypervisor-%s", gpuNode.Name),
 				Namespace: utils.CurrentNamespace(),
 			}, pod)).Should(Succeed())
 			g.Expect(pod.Labels[constants.LabelKeyPodTemplateHash]).Should(Equal(hash))
@@ -552,7 +552,7 @@ func verifyAllHypervisorPodHashConsistently(tfEnv *TensorFusionEnv, hash string)
 		for _, gpuNode := range nodeList.Items {
 			pod := &corev1.Pod{}
 			g.Expect(k8sClient.Get(ctx, client.ObjectKey{
-				Name:      fmt.Sprintf("hypervisor-%s", gpuNode.Name),
+				Name:      fmt.Sprintf("tf-hypervisor-%s", gpuNode.Name),
 				Namespace: utils.CurrentNamespace(),
 			}, pod)).Should(Succeed())
 			g.Expect(pod.Labels[constants.LabelKeyPodTemplateHash]).Should(Equal(hash))