Method query

cmd/prometheus/query_log_test.go:99–145

query runs a query according to the test origin.

(t *testing.T)

// query runs a query according to the test origin.
func (p *queryLogTest) query(t *testing.T) {
	switch p.origin {
	case apiOrigin:
		r, err := http.Get(fmt.Sprintf(
			"http://%s:%d%s/api/v1/query_range?step=5&start=0&end=3600&query=%s",
			p.host,
			p.port,
			p.prefix,
			url.QueryEscape("query_with_api"),
		))
		require.NoError(t, err)
		require.Equal(t, 200, r.StatusCode)
	case consoleOrigin:
		r, err := http.Get(fmt.Sprintf(
			"http://%s:%d%s/consoles/test.html",
			p.host,
			p.port,
			p.prefix,
		))
		require.NoError(t, err)
		require.Equal(t, 200, r.StatusCode)
	case ruleOrigin:
		// Poll the /api/v1/rules endpoint until a new rule evaluation is detected.
		var lastEvalTime time.Time
		for {
			r, err := http.Get(fmt.Sprintf("http://%s:%d/api/v1/rules", p.host, p.port))
			require.NoError(t, err)

			rulesBody, err := io.ReadAll(r.Body)
			require.NoError(t, err)
			defer r.Body.Close()

			// Parse the rules response to find the last evaluation time.
			newEvalTime := parseLastEvaluation(rulesBody)
			if newEvalTime.After(lastEvalTime) {
				if !lastEvalTime.IsZero() {
					break
				}
				lastEvalTime = newEvalTime
			}

			time.Sleep(100 * time.Millisecond)
		}
	default:
		panic("can't query this origin")
	}
}

// parseLastEvaluation extracts the last evaluation timestamp from the /api/v1/rules response.
func parseLastEvaluation(rulesBody []byte) time.Time {