Function Test_gauge_demandVsActiveSeries

modules/generator/registry/gauge_test.go:317–356

(t *testing.T)

}

func Test_gauge_demandVsActiveSeries(t *testing.T) {
	limitReached := false
	overflowLabels := labels.FromStrings("metric_overflow", "true")
	overflowHash := overflowLabels.Hash()

	lifecycler := &mockLimiter{
		onAddFunc: func(hash uint64, _ uint32, lbls labels.Labels) (labels.Labels, uint64) {
			if !limitReached {
				return lbls, hash
			}
			return overflowLabels, overflowHash
		},
	}
	g := newGauge("my_gauge", lifecycler, map[string]string{}, 15*time.Minute)

	// Add series up to a point
	for i := 0; i < 30; i++ {
		lbls := buildTestLabels([]string{"label"}, []string{fmt.Sprintf("value-%d", i)})
		g.Set(lbls, float64(i))
	}

	assert.Equal(t, 30, g.countActiveSeries())

	// Hit the limit
	limitReached = true

	// Try to add more series (they should be mapped to overflow)
	for i := 30; i < 60; i++ {
		lbls := buildTestLabels([]string{"label"}, []string{fmt.Sprintf("value-%d", i)})
		g.Set(lbls, float64(i))
	}

	// Active series should be 30 accepted + 1 overflow = 31 total
	assert.Equal(t, 31, g.countActiveSeries())

	// But demand should show all attempted series
	demand := g.countSeriesDemand()
	assert.Greater(t, demand, 50, "demand should track all attempted series")
	assert.Greater(t, demand, g.countActiveSeries(), "demand should exceed active series")
}

func Test_gauge_demandDecay(t *testing.T) {
	lifecycler := &mockLimiter{}