From c7876d4111e93229d433260d7adbc7d0fccc8865 Mon Sep 17 00:00:00 2001 From: Xiang Li Date: Tue, 2 Feb 2016 20:48:34 -0800 Subject: [PATCH] clientv3/integration: fix member remove Do not connect to the member to remove. --- clientv3/integration/cluster_test.go | 2 +- integration/cluster.go | 4 ++++ 2 files changed, 5 insertions(+), 1 deletion(-) diff --git a/clientv3/integration/cluster_test.go b/clientv3/integration/cluster_test.go index 6fa3bd8b0..a0fea37ea 100644 --- a/clientv3/integration/cluster_test.go +++ b/clientv3/integration/cluster_test.go @@ -67,7 +67,7 @@ func TestMemberRemove(t *testing.T) { clus := integration.NewClusterV3(t, &integration.ClusterConfig{Size: 3}) defer clus.Terminate(t) - capi := clientv3.NewCluster(clus.RandClient()) + capi := clientv3.NewCluster(clus.Client(1)) resp, err := capi.MemberList(context.Background()) if err != nil { t.Fatalf("failed to list member %v", err) diff --git a/integration/cluster.go b/integration/cluster.go index 666ffab86..0a0c661e4 100644 --- a/integration/cluster.go +++ b/integration/cluster.go @@ -696,3 +696,7 @@ func (c *ClusterV3) Terminate(t *testing.T) { func (c *ClusterV3) RandClient() *clientv3.Client { return c.clients[rand.Intn(len(c.clients))] } + +func (c *ClusterV3) Client(i int) *clientv3.Client { + return c.clients[i] +}