Method Query

integration/e2ecortex/client.go:399–421

Query runs an instant query.

(query string, ts time.Time)

// Query runs an instant query.
func (c *Client) Query(query string, ts time.Time) (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.Query(context.Background(), query, ts)
		if err == nil {
			break
		}
		if !strings.Contains(err.Error(), "EOF") {
			break
		}
		retries.Wait()
	}
	return value, err
}

// Metadata runs a metadata query
func (c *Client) Metadata(name, limit string) (map[string][]promv1.Metadata, error) {