Function assertMetrics

pkg/acquisition/modules/http/http_test.go:735–770

(t *testing.T, reg *prometheus.Registry, metrics []prometheus.Collector, expected int)

}

func assertMetrics(t *testing.T, reg *prometheus.Registry, metrics []prometheus.Collector, expected int) {
	promMetrics, err := reg.Gather()
	require.NoError(t, err)

	isExist := false

	for _, metricFamily := range promMetrics {
		if metricFamily.GetName() == "cs_httpsource_hits_total" {
			isExist = true

			assert.Len(t, metricFamily.GetMetric(), 1)

			for _, metric := range metricFamily.GetMetric() {
				assert.InDelta(t, float64(expected), metric.GetCounter().GetValue(), 0.000001)
				labels := metric.GetLabel()
				assert.Len(t, labels, 4)
				assert.Equal(t, "acquis_type", labels[0].GetName())
				assert.Empty(t, labels[0].GetValue())
				assert.Equal(t, "datasource_type", labels[1].GetName())
				assert.Equal(t, "http", labels[1].GetValue())
				assert.Equal(t, "path", labels[2].GetName())
				assert.Equal(t, "/test", labels[2].GetValue())
				assert.Equal(t, "src", labels[3].GetName())
				assert.Equal(t, "127.0.0.1", labels[3].GetValue())
			}
		}
	}

	if !isExist && expected > 0 {
		t.Fatal("expected metric cs_httpsource_hits_total not found")
	}

	for _, metric := range metrics {
		metric.(*prometheus.CounterVec).Reset()
	}
}