Skip to content

Commit

Permalink
Adjust test
Browse files Browse the repository at this point in the history
Signed-off-by: Matt Lord <mattalord@gmail.com>
  • Loading branch information
mattlord committed Feb 6, 2025
1 parent 99ae206 commit 2e6f38a
Showing 1 changed file with 3 additions and 2 deletions.
5 changes: 3 additions & 2 deletions go/test/endtoend/vreplication/migrate_test.go
Original file line number Diff line number Diff line change
Expand Up @@ -96,8 +96,9 @@ func TestMigrateUnsharded(t *testing.T) {
var output, expected string

t.Run("mount external cluster", func(t *testing.T) {
etcdHostPort := fmt.Sprintf("localhost:%d", extVc.ClusterConfig.topoPort)
output, err := vc.VtctldClient.ExecuteCommandWithOutput("Mount", "register", "--name=ext1", "--topo-type=etcd2",
fmt.Sprintf("--topo-server=localhost:%d", extVc.ClusterConfig.topoPort), "--topo-root=/vitess/global")
"--topo-server", etcdHostPort, "--topo-root=/vitess/global")
require.NoError(t, err, "Mount Register command failed with %s", output)

output, err = vc.VtctldClient.ExecuteCommandWithOutput("Mount", "list")
Expand All @@ -110,7 +111,7 @@ func TestMigrateUnsharded(t *testing.T) {
require.NoError(t, err, "Mount command failed with %s\n", output)

require.Equal(t, "etcd2", gjson.Get(output, "topo_type").String())
require.Equal(t, "localhost:12379", gjson.Get(output, "topo_server").String())
require.Equal(t, etcdHostPort, gjson.Get(output, "topo_server").String())
require.Equal(t, "/vitess/global", gjson.Get(output, "topo_root").String())
})

Expand Down

0 comments on commit 2e6f38a

Please sign in to comment.