Function waitRingInstance

ring/lifecycler_test.go:2005–2024

(t *testing.T, timeout time.Duration, l *Lifecycler, check func(instance InstanceDesc) error)

}

func waitRingInstance(t *testing.T, timeout time.Duration, l *Lifecycler, check func(instance InstanceDesc) error) {
	test.Poll(t, timeout, nil, func() interface{} {
		desc, err := l.KVStore.Get(context.Background(), l.RingKey)
		if err != nil {
			return err
		}

		ringDesc, ok := desc.(*Desc)
		if !ok || ringDesc == nil {
			return errors.New("empty ring")
		}

		instance, ok := ringDesc.Ingesters[l.ID]
		if !ok {
			return errors.New("no instance in the ring")
		}

		return check(instance)
	})
}

func TestDefaultFinalSleepValue(t *testing.T) {
	t.Parallel()