We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
There was an error while loading. Please reload this page.
1 parent 5e078f9 commit c1023f3Copy full SHA for c1023f3
pkg/storegateway/gateway_test.go
@@ -300,7 +300,10 @@ func TestStoreGateway_InitialSyncWithWaitRingStability(t *testing.T) {
300
t.Log("random generator seed:", seed)
301
302
ctx := context.Background()
303
- ringStore := consul.NewInMemoryClient(ring.GetCodec())
+ ringStore := consul.NewInMemoryClientWithConfig(ring.GetCodec(), consul.Config{
304
+ MaxCasRetries: 20,
305
+ CasRetryDelay: 500 * time.Millisecond,
306
+ })
307
308
// Create the configured number of gateways.
309
var gateways []*StoreGateway
0 commit comments