Function verifySamples

pkg/testexporter/correctness/simple.go:155–186

(log *spanlogger.SpanLogger, tc Case, pairs []model.SamplePair, duration time.Duration, cfg CommonTestConfig)

}

func verifySamples(log *spanlogger.SpanLogger, tc Case, pairs []model.SamplePair, duration time.Duration, cfg CommonTestConfig) bool {
	for _, pair := range pairs {
		correct := timeEpsilonCorrect(tc.ExpectedValueAt, pair, cfg.testTimeEpsilon) || valueEpsilonCorrect(tc.ExpectedValueAt, pair, cfg.testEpsilon)
		if correct {
			sampleResult.WithLabelValues(tc.Name(), success).Inc()
		} else {
			sampleResult.WithLabelValues(tc.Name(), fail).Inc()
			level.Error(log).Log("msg", "wrong value", "at", pair.Timestamp, "expected", tc.ExpectedValueAt(pair.Timestamp.Time()), "actual", pair.Value)
			log.Error(fmt.Errorf("wrong value"))
			return false
		}
	}

	// when verifying a deleted series we get samples for very short interval. As small as 1 or 2 missing/extra samples can cause test to fail.
	if duration > 5*time.Minute {
		expectedNumSamples := int(duration / cfg.ScrapeInterval)
		if !epsilonCorrect(float64(len(pairs)), float64(expectedNumSamples), cfg.samplesEpsilon) {
			level.Error(log).Log("msg", "wrong number of samples", "expected", expectedNumSamples, "actual", len(pairs))
			log.Error(fmt.Errorf("wrong number of samples"))
			return false
		}
	} else {
		expectedNumSamples := int(duration / cfg.ScrapeInterval)
		if math.Abs(float64(expectedNumSamples-len(pairs))) > 2 {
			level.Error(log).Log("msg", "wrong number of samples", "expected", expectedNumSamples, "actual", len(pairs))
			log.Error(fmt.Errorf("wrong number of samples"))
			return false
		}
	}

	return true
}

func timeEpsilonCorrect(f func(time.Time) float64, pair model.SamplePair, testTimeEpsilon time.Duration) bool {
	minExpected := f(pair.Timestamp.Time().Add(-testTimeEpsilon))