mirrors/etcd
1
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

clientv3/integration: fix member remove

Browse Source 
Do not connect to the member to remove.
This commit is contained in:
Xiang Li
2016-02-02 20:48:34 -08:00
parent 83411b92b4
commit c7876d4111
2 changed files with 5 additions and 1 deletions
Download Patch File Download Diff File Expand all files Collapse all files

2
clientv3/integration/cluster_test.go
View File

@ -67,7 +67,7 @@ func TestMemberRemove(t *testing.T) {
clus := integration.NewClusterV3(t, &integration.ClusterConfig{Size: 3}) clus := integration.NewClusterV3(t, &integration.ClusterConfig{Size: 3})
defer clus.Terminate(t) defer clus.Terminate(t)
capi := clientv3.NewCluster(clus.RandClient()) capi := clientv3.NewCluster(clus.Client(1))
resp, err := capi.MemberList(context.Background()) resp, err := capi.MemberList(context.Background())
if err != nil { if err != nil {
t.Fatalf("failed to list member %v", err) t.Fatalf("failed to list member %v", err)

4
integration/cluster.go
View File

@ -696,3 +696,7 @@ func (c *ClusterV3) Terminate(t *testing.T) {
func (c *ClusterV3) RandClient() *clientv3.Client { func (c *ClusterV3) RandClient() *clientv3.Client {
return c.clients[rand.Intn(len(c.clients))] return c.clients[rand.Intn(len(c.clients))]
} }
func (c *ClusterV3) Client(i int) *clientv3.Client {
return c.clients[i]
}