feat: fix build issue in tests

Signed-off-by: Manan Gupta <[email protected]>
vitessio · Jan 22, 2025 · 30949f7 · 30949f7
1 parent 78e60e2
commit 30949f7
Show file tree

Hide file tree

Showing 3 changed files with 3 additions and 3 deletions.
diff --git a/go/test/endtoend/topotest/consul/main_test.go b/go/test/endtoend/topotest/consul/main_test.go
@@ -228,7 +228,7 @@ func TestKeyspaceLocking(t *testing.T) {
 // from the watch.
 func TestWatchAllKeyspaceRecords(t *testing.T) {
 	// Create the topo server connection.
-	ts, err := topo.OpenServer(*clusterInstance.TopoFlavorString(), clusterInstance.VtctlProcess.TopoGlobalAddress, clusterInstance.VtctlProcess.TopoGlobalRoot)
+	ts, err := topo.OpenServer(*clusterInstance.TopoFlavorString(), clusterInstance.VtctldProcess.TopoGlobalAddress, clusterInstance.VtctldProcess.TopoGlobalRoot)
 	require.NoError(t, err)
 
 	watchCtx, watchCancel := context.WithCancel(context.Background())

diff --git a/go/test/endtoend/topotest/etcd2/main_test.go b/go/test/endtoend/topotest/etcd2/main_test.go
@@ -275,7 +275,7 @@ func TestNamedLocking(t *testing.T) {
 // from the watch.
 func TestWatchAllKeyspaceRecords(t *testing.T) {
 	// Create the topo server connection.
-	ts, err := topo.OpenServer(*clusterInstance.TopoFlavorString(), clusterInstance.VtctlProcess.TopoGlobalAddress, clusterInstance.VtctlProcess.TopoGlobalRoot)
+	ts, err := topo.OpenServer(*clusterInstance.TopoFlavorString(), clusterInstance.VtctldProcess.TopoGlobalAddress, clusterInstance.VtctldProcess.TopoGlobalRoot)
 	require.NoError(t, err)
 
 	watchCtx, watchCancel := context.WithCancel(context.Background())

diff --git a/go/test/endtoend/topotest/zk2/main_test.go b/go/test/endtoend/topotest/zk2/main_test.go
@@ -204,7 +204,7 @@ func TestKeyspaceLocking(t *testing.T) {
 // from the watch.
 func TestWatchAllKeyspaceRecords(t *testing.T) {
 	// Create the topo server connection.
-	ts, err := topo.OpenServer(*clusterInstance.TopoFlavorString(), clusterInstance.VtctlProcess.TopoGlobalAddress, clusterInstance.VtctlProcess.TopoGlobalRoot)
+	ts, err := topo.OpenServer(*clusterInstance.TopoFlavorString(), clusterInstance.VtctldProcess.TopoGlobalAddress, clusterInstance.VtctldProcess.TopoGlobalRoot)
 	require.NoError(t, err)
 
 	watchCtx, watchCancel := context.WithCancel(context.Background())