Method QueryRange

integration/e2ecortex/client.go:437–464

QueryRange runs a query range.

(query string, start, end time.Time, step time.Duration)

// QueryRange runs a query range.
func (c *Client) QueryRange(query string, start, end time.Time, step time.Duration) (model.Value, error) {
	ctx := context.Background()
	retries := backoff.New(ctx, backoff.Config{
		MinBackoff: 1 * time.Second,
		MaxBackoff: 3 * time.Second,
		MaxRetries: 5,
	})
	var (
		value model.Value
		err   error
	)
	for retries.Ongoing() {
		value, _, err = c.querierClient.QueryRange(context.Background(), query, promv1.Range{
			Start: start,
			End:   end,
			Step:  step,
		})
		if err == nil {
			break
		}
		if !strings.Contains(err.Error(), "EOF") {
			break
		}
		retries.Wait()
	}

	return value, err
}

// QueryRangeRaw runs a ranged query directly against the querier API.
func (c *Client) QueryRangeRaw(query string, start, end time.Time, step time.Duration, headers map[string]string) (*http.Response, []byte, error) {