scriptoriumadmin/featurebase
1
0
Fork 0
mirror of https://github.com/featurebasedb/featurebase.git synced 2026-10-09 20:37:52 +00:00
Code Issues Projects Releases Packages Wiki Activity Actions

add retry to MustRunCluster

Browse source
This commit is contained in:
Travis 2021-01-12 22:09:09 -06:00
parent bc13834343
commit f2234929d8
No known key found for this signature in database
GPG key ID: 37080CC2042BA34E
1 changed files with 15 additions and 3 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

18
test/cluster.go
View file

@ -414,11 +414,23 @@ func newCluster(tb testing.TB, size int, opts ...[]server.CommandOption) (*Clust
// MustRunCluster creates and starts a new cluster. The opts parameter
// is slightly magical; see MustNewCluster.
func MustRunCluster(tb testing.TB, size int, opts ...[]server.CommandOption) *Cluster {
cluster := MustNewCluster(tb, size, opts...)
if err := cluster.Start(); err != nil {
var tries int = 5
var cluster *Cluster
var err error
for i := 0; i < tries; i++ {
if i > 0 {
fmt.Printf("--- try starting cluster again: %d\n", i)
}
cluster = MustNewCluster(tb, size, opts...)
if err = cluster.Start(); err == nil {
break
}
}
if err != nil {
tb.Fatalf("run cluster: %v", err)
}
fmt.Printf("done with AwaitState\n")
return cluster
}