@@ -332,7 +332,7 @@ func TestTokensOnDisk(t *testing.T) {
332
332
flagext .DefaultValues (& ringConfig )
333
333
ringConfig .KVStore .Mock = consul .NewInMemoryClient (GetCodec ())
334
334
335
- r , err := New (ringConfig , "ingester" )
335
+ r , err := New (ringConfig , "ingester" , IngesterRingKey )
336
336
require .NoError (t , err )
337
337
defer r .Stop ()
338
338
@@ -348,13 +348,13 @@ func TestTokensOnDisk(t *testing.T) {
348
348
lifecyclerConfig .NormaliseTokens = true
349
349
350
350
// Start first ingester.
351
- l1 , err := NewLifecycler (lifecyclerConfig , & noopFlushTransferer {}, "ingester" )
351
+ l1 , err := NewLifecycler (lifecyclerConfig , & noopFlushTransferer {}, "ingester" , IngesterRingKey )
352
352
require .NoError (t , err )
353
353
l1 .Start ()
354
354
// Check this ingester joined, is active, and has 512 token.
355
355
var expTokens []uint32
356
356
test .Poll (t , 1000 * time .Millisecond , true , func () interface {} {
357
- d , err := r .KVClient .Get (context .Background (), ConsulKey )
357
+ d , err := r .KVClient .Get (context .Background (), IngesterRingKey )
358
358
require .NoError (t , err )
359
359
desc , ok := d .(* Desc )
360
360
if ok {
@@ -371,15 +371,15 @@ func TestTokensOnDisk(t *testing.T) {
371
371
372
372
// Start new ingester at same token directory.
373
373
lifecyclerConfig .ID = "ing2"
374
- l2 , err := NewLifecycler (lifecyclerConfig , & noopFlushTransferer {}, "ingester" )
374
+ l2 , err := NewLifecycler (lifecyclerConfig , & noopFlushTransferer {}, "ingester" , IngesterRingKey )
375
375
require .NoError (t , err )
376
376
l2 .Start ()
377
377
defer l2 .Shutdown ()
378
378
379
379
// Check this ingester joined, is active, and has 512 token.
380
380
var actTokens []uint32
381
381
test .Poll (t , 1000 * time .Millisecond , true , func () interface {} {
382
- d , err := r .KVClient .Get (context .Background (), ConsulKey )
382
+ d , err := r .KVClient .Get (context .Background (), IngesterRingKey )
383
383
require .NoError (t , err )
384
384
desc , ok := d .(* Desc )
385
385
if ok {
0 commit comments