Added remotedatanodes.cluster.ytsaurus.tech.yaml to ytop/templates/cr…

…ds manually
ytsaurus · Aug 29, 2024 · 76d528b · 76d528b
1 parent c92e3e4
commit 76d528b
Show file tree

Hide file tree

Showing 2 changed files with 2,548 additions and 1 deletion.
diff --git a/test/e2e/ytsaurus_controller_test.go b/test/e2e/ytsaurus_controller_test.go
@@ -207,7 +207,7 @@ func runRemoteExecNodes(remoteExecNodes *ytv1.RemoteExecNodes) {
 		return err == nil
 	}, reactionTimeout, pollInterval).Should(BeTrue())
 
-	By("Checking that remote nodes state is equal to `Running`")
+	By("Checking that remote exec nodes state is equal to `Running`")
 	Eventually(
 		func() (*ytv1.RemoteExecNodes, error) {
 			nodes := &ytv1.RemoteExecNodes{}
@@ -225,6 +225,33 @@ func deleteRemoteExecNodes(ctx context.Context, remoteExecNodes *ytv1.RemoteExec
 	}
 }
 
+// func runRemoteDataNodes(remoteDataNodes *ytv1.RemoteDataNodes) {
+//	Expect(k8sClient.Create(ctx, remoteDataNodes)).Should(Succeed())
+//	lookupKey := types.NamespacedName{Name: remoteDataNodes.Name, Namespace: remoteDataNodes.Namespace}
+//	Eventually(func() bool {
+//		createdYtsaurus := &ytv1.RemoteDataNodes{}
+//		err := k8sClient.Get(ctx, lookupKey, createdYtsaurus)
+//		return err == nil
+//	}, reactionTimeout, pollInterval).Should(BeTrue())
+//
+//	By("Checking that remote data nodes state is equal to `Running`")
+//	Eventually(
+//		func() (*ytv1.RemoteDataNodes, error) {
+//			nodes := &ytv1.RemoteDataNodes{}
+//			err := k8sClient.Get(ctx, lookupKey, nodes)
+//			return nodes, err
+//		},
+//		reactionTimeout*2,
+//		pollInterval,
+//	).Should(HaveField("Status.ReleaseStatus", ytv1.RemoteDataNodeReleaseStatusRunning))
+//}
+//
+// func deleteRemoteDataNodes(ctx context.Context, remoteDataNodes *ytv1.RemoteDataNodes) {
+//	if err := k8sClient.Delete(ctx, remoteDataNodes); err != nil {
+//		log.Error(err, "Deleting remote ytsaurus failed")
+//	}
+//}
+
 func runImpossibleUpdateAndRollback(ytsaurus *ytv1.Ytsaurus, ytClient yt.Client) {
 	name := types.NamespacedName{Name: ytsaurus.Name, Namespace: ytsaurus.Namespace}