mirror of https://github.com/etcd-io/dbtester.git
control: add more loggins for key count
This commit is contained in:
parent
38952dd5ce
commit
9a6277d5d1
|
|
@ -218,9 +218,9 @@ func step2(cfg Config) error {
|
|||
}
|
||||
reqGen := func(reqs chan<- request) { generateWrites(cfg, vals, reqs) }
|
||||
generateReport(cfg, h, reqGen)
|
||||
plog.Println("generateReport is finished...")
|
||||
|
||||
plog.Println("generateReport is finished... checking total keys")
|
||||
|
||||
plog.Println("checking total keys on", cfg.DatabaseEndpoints)
|
||||
var totalKeysFunc func([]string) map[string]int64
|
||||
switch cfg.Database {
|
||||
case "etcdv2":
|
||||
|
|
|
|||
|
|
@ -195,6 +195,8 @@ func getTotalKeysEtcdv3(endpoints []string) map[string]int64 {
|
|||
if !strings.HasPrefix(ep, "http://") {
|
||||
ep = "http://" + ep
|
||||
}
|
||||
|
||||
plog.Println("GET", ep+"/metrics")
|
||||
resp, err := http.Get(ep + "/metrics")
|
||||
if err != nil {
|
||||
plog.Println(err)
|
||||
|
|
@ -221,6 +223,8 @@ func getTotalKeysEtcdv3(endpoints []string) map[string]int64 {
|
|||
}
|
||||
gracefulClose(resp)
|
||||
}
|
||||
|
||||
plog.Println("getTotalKeysEtcdv3", rs)
|
||||
return rs
|
||||
}
|
||||
|
||||
|
|
|
|||
Loading…
Reference in New Issue