Function TestCheckMetricConsistency

prometheus/registry_test.go:1310–1342

TestCheckMetricConsistency

(t *testing.T)

// TestCheckMetricConsistency
func TestCheckMetricConsistency(t *testing.T) {
	reg := prometheus.NewRegistry()
	timestamp := time.Now()

	desc := prometheus.NewDesc("metric_a", "", nil, nil)
	metric := prometheus.MustNewConstMetric(desc, prometheus.CounterValue, 1)

	validCollector := &customCollector{
		collectFunc: func(ch chan<- prometheus.Metric) {
			ch <- prometheus.NewMetricWithTimestamp(timestamp.Add(-1*time.Minute), metric)
			ch <- prometheus.NewMetricWithTimestamp(timestamp, metric)
		},
	}
	reg.MustRegister(validCollector)
	_, err := reg.Gather()
	if err != nil {
		t.Error("metric validation should succeed:", err)
	}
	reg.Unregister(validCollector)

	invalidCollector := &customCollector{
		collectFunc: func(ch chan<- prometheus.Metric) {
			ch <- prometheus.NewMetricWithTimestamp(timestamp, metric)
			ch <- prometheus.NewMetricWithTimestamp(timestamp, metric)
		},
	}
	reg.MustRegister(invalidCollector)
	_, err = reg.Gather()
	if err == nil {
		t.Error("metric validation should return an error")
	}
	reg.Unregister(invalidCollector)
}

func TestGatherDoesNotLeakGoroutines(t *testing.T) {
	// Use goleak to verify that no unexpected goroutines are leaked during the test.