Function Test_gauge_concurrencyDataRace

modules/generator/registry/gauge_test.go:214–258

(t *testing.T)

}

func Test_gauge_concurrencyDataRace(t *testing.T) {
	c := newGauge("my_gauge", noopLimiter, map[string]string{}, 15*time.Minute)

	end := make(chan struct{})

	accessor := func(f func()) {
		for {
			select {
			case <-end:
				return
			default:
				f()
			}
		}
	}

	for i := 0; i < 4; i++ {
		go accessor(func() {
			c.Inc(buildTestLabels([]string{"label"}, []string{"value-1"}), 1.0)
			c.Inc(buildTestLabels([]string{"label"}, []string{"value-2"}), 1.0)
		})
	}

	// this goroutine constantly creates new series
	letters := []rune("abcdefghijklmnopqrstuvwxyzABCDEFGHIJKLMNOPQRSTUVWXYZ")
	go accessor(func() {
		s := make([]rune, 6)
		for i := range s {
			s[i] = letters[rand.Intn(len(letters))]
		}
		c.Inc(buildTestLabels([]string{"label"}, []string{string(s)}), 1.0)
	})

	go accessor(func() {
		err := c.collectMetrics(&noopAppender{}, 0)
		assert.NoError(t, err)
	})

	go accessor(func() {
		c.removeStaleSeries(time.Now().UnixMilli())
	})

	time.Sleep(200 * time.Millisecond)
	close(end)
}

func Test_gauge_concurrencyCorrectness(t *testing.T) {
	c := newGauge("my_gauge", noopLimiter, map[string]string{}, 15*time.Minute)