github/kubernetes
4
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

Delete all keys prior to running integration test

Browse Source
This commit is contained in:
Clayton Coleman
2014-08-28 00:32:04 -04:00
parent 4379fabd5e
commit e840062c65
1 changed files with 9 additions and 0 deletions
Download Patch File Download Diff File Expand all files Collapse all files

9
cmd/integration/integration.go
View File

@@ -94,6 +94,15 @@ func startComponents(manifestURL string) (apiServerURL string) {
apiServer := httptest.NewServer(&handler) apiServer := httptest.NewServer(&handler)
etcdClient := etcd.NewClient(servers) etcdClient := etcd.NewClient(servers)
keys, err := etcdClient.Get("/", false, false)
if err != nil {
glog.Fatalf("Unable to list root etcd keys: %v", err)
}
for _, node := range keys.Node.Nodes {
if _, err := etcdClient.Delete(node.Key, true); err != nil {
glog.Fatalf("Unable delete key: %v", err)
}
}
cl := client.New(apiServer.URL, nil) cl := client.New(apiServer.URL, nil)
cl.PollPeriod = time.Second * 1 cl.PollPeriod = time.Second * 1