Add channel in qt config

pkg/components/query_tracker.go

@@ -268,8 +268,9 @@ func (qt *QueryTracker) init(ctx context.Context, ytClient yt.Client) (err error
 		map[string]interface{}{
 			"stages": map[string]interface{}{
 				"production": map[string]interface{}{
-					"root": "//sys/query_tracker",
-					"user": "query_tracker",
+					"root":    "//sys/query_tracker",
+					"user":    "query_tracker",
+					"channel": map[string]interface{}{"addresses": qt.cfgen.GetQueryTrackerAddresses()},
 				},
 			},
 		},

pkg/ytconfig/generator.go

@@ -111,6 +111,19 @@ func (g *Generator) GetYQLAgentAddresses() []string {
 	return names
 }
 
+func (g *Generator) GetQueryTrackerAddresses() []string {
+	names := make([]string, 0, g.ytsaurus.Spec.QueryTrackers.InstanceCount)
+	for _, podName := range g.GetQueryTrackerPodNames() {
+		names = append(names, fmt.Sprintf("%s.%s.%s.svc.%s:%d",
+			podName,
+			g.GetQueryTrackerServiceName(),
+			g.ytsaurus.Namespace,
+			g.clusterDomain,
+			consts.QueryTrackerRPCPort))
+	}
+	return names
+}
+
 func (g *Generator) GetQueueAgentAddresses() []string {
 	names := make([]string, 0, g.ytsaurus.Spec.QueueAgents.InstanceCount)
 	for _, podName := range g.GetQueueAgentPodNames() {

pkg/ytconfig/names.go

@@ -56,6 +56,15 @@ func (g *BaseGenerator) GetDiscoveryPodNames() []string {
 	return podNames
 }
 
+func (g *Generator) GetQueryTrackerPodNames() []string {
+	podNames := make([]string, 0, g.ytsaurus.Spec.QueryTrackers.InstanceSpec.InstanceCount)
+	for i := 0; i < int(g.ytsaurus.Spec.QueryTrackers.InstanceSpec.InstanceCount); i++ {
+		podNames = append(podNames, fmt.Sprintf("%s-%d", g.GetQueryTrackerStatefulSetName(), i))
+	}
+
+	return podNames
+}
+
 func (g *Generator) GetYQLAgentPodNames() []string {
 	podNames := make([]string, 0, g.ytsaurus.Spec.YQLAgents.InstanceSpec.InstanceCount)
 	for i := 0; i < int(g.ytsaurus.Spec.YQLAgents.InstanceSpec.InstanceCount); i++ {

test/e2e/ytsaurus_controller_test.go

@@ -564,6 +564,26 @@ var _ = Describe("Basic test for Ytsaurus controller", func() {
 			runImpossibleUpdateAndRollback(ytsaurus, ytClient)
 		})
 
+		It("Should run with query tracker and check that query tracker rpc address set up correctly", Label("basic"), func(ctx context.Context) {
+			By("Creating a Ytsaurus resource")
+
+			namespace := "querytrackeraddress"
+
+			ytsaurus := ytv1.CreateBaseYtsaurusResource(namespace)
+			ytsaurus = ytv1.WithQueryTracker(ytsaurus)
+
+			g := ytconfig.NewGenerator(ytsaurus, "local")
+
+			DeferCleanup(deleteYtsaurus, ytsaurus)
+			runYtsaurus(ytsaurus)
+
+			By("Creating ytsaurus client")
+			ytClient := getYtClient(g, namespace)
+
+			By("Check that query tracker channel exists in cluster_connection")
+			Expect(ytClient.NodeExists(ctx, ypath.Path("//sys/@cluster_connection/query_tracker/stages/production/channel"), nil)).Should(BeTrue())
+		})
+
 		It("Should run with query tracker and check that access control objects set up correctly", Label("basic"), func(ctx context.Context) {
 			By("Creating a Ytsaurus resource")