Function Test_gauge_concurrencyCorrectness

modules/generator/registry/gauge_test.go:260–294

(t *testing.T)

}

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

	var wg sync.WaitGroup
	end := make(chan struct{})

	totalCount := atomic.NewUint64(0)

	for i := 0; i < 4; i++ {
		wg.Add(1)
		go func() {
			defer wg.Done()
			for {
				select {
				case <-end:
					return
				default:
					c.Inc(buildTestLabels([]string{"label"}, []string{"value-1"}), 1.0)
					totalCount.Inc()
				}
			}
		}()
	}

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

	wg.Wait()

	collectionTimeMs := time.Now().UnixMilli()
	expectedSamples := []sample{
		newSample(map[string]string{"__name__": "my_gauge", "label": "value-1"}, collectionTimeMs, float64(totalCount.Load())),
	}
	collectMetricAndAssert(t, c, collectionTimeMs, 1, expectedSamples, nil)
}

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