Mirroristas/etcd
2
0
Fork 0
mirror of https://github.com/etcd-io/etcd.git synced 2024-09-27 06:25:44 +00:00
Code Issues Packages Projects Releases Wiki Activity

test: Migrate WaitMembersForLeader to V3 API

Browse Source
This commit is contained in:
Marek Siarkowicz 2022-01-24 13:10:45 +01:00
parent 81490c25d1
commit c59694d41e
1 changed files with 5 additions and 4 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

9
tests/framework/integration/cluster.go
View File

@ -419,13 +419,14 @@ func (c *Cluster) WaitMembersForLeader(t testutil.TB, membs []*Member) int {
for _, m := range membs { for _, m := range membs {
possibleLead[uint64(m.Server.ID())] = true possibleLead[uint64(m.Server.ID())] = true
} }
cc := MustNewHTTPClient(t, getMembersURLs(membs), nil) cc, err := c.ClusterClient()
kapi := client.NewKeysAPI(cc) if err != nil {
t.Fatal(err)
}
// ensure leader is up via linearizable get // ensure leader is up via linearizable get
for { for {
ctx, cancel := context.WithTimeout(context.Background(), 10*TickDuration+time.Second) ctx, cancel := context.WithTimeout(context.Background(), 10*TickDuration+time.Second)
_, err := kapi.Get(ctx, "0", &client.GetOptions{Quorum: true}) _, err := cc.Get(ctx, "0")
cancel() cancel()
if err == nil || strings.Contains(err.Error(), "Key not found") { if err == nil || strings.Contains(err.Error(), "Key not found") {
break break