Function collectMetricAndAssert

modules/generator/registry/counter_test.go:281–299

(t *testing.T, m metric, collectionTimeMs int64, expectedActiveSeries int, expectedSamples []sample, expectedExemplars []exemplarSample)

}

func collectMetricAndAssert(t *testing.T, m metric, collectionTimeMs int64, expectedActiveSeries int, expectedSamples []sample, expectedExemplars []exemplarSample) {
	appender := &capturingAppender{}

	err := m.collectMetrics(appender, collectionTimeMs)
	assert.NoError(t, err)

	assert.False(t, appender.isCommitted)
	assert.False(t, appender.isRolledback)
	assert.ElementsMatch(t, expectedSamples, appender.samples)
	fmt.Println("Expected samples:")
	for _, expectedSample := range expectedSamples {
		fmt.Println(" - ", expectedSample.l, expectedSample.v)
	}
	fmt.Println("Appender samples:")
	for _, sample := range appender.samples {
		fmt.Println(" - ", sample.l, sample.v)
	}
	assert.ElementsMatch(t, expectedExemplars, appender.exemplars)
}

func Test_counter_demandTracking(t *testing.T) {
	c := newCounter("my_counter", noopLimiter, map[string]string{}, 15*time.Minute)