Method InstantQuery

pkg/ruler/frontend_client.go:90–129

(ctx context.Context, qs string, t time.Time)

}

func (p *FrontendClient) InstantQuery(ctx context.Context, qs string, t time.Time) (promql.Vector, error) {
	log, ctx := spanlogger.New(ctx, "FrontendClient.InstantQuery")
	defer log.Finish()

	req, err := p.makeRequest(ctx, qs, t)
	if err != nil {
		level.Error(log).Log("err", err, "query", qs)
		return nil, err
	}

	ctx, cancel := context.WithTimeout(ctx, p.timeout)
	defer cancel()

	resp, err := p.client.Handle(ctx, req)

	if err != nil {
		level.Error(log).Log("err", err, "query", qs)
		return nil, err
	}

	contentType := extractHeader(resp.Headers, "Content-Type")
	decoder, ok := p.decoders[contentType]
	if !ok {
		err = fmt.Errorf("unknown content type: %s", contentType)
		level.Error(log).Log("err", err, "query", qs)
		return nil, err
	}

	vector, warning, err := decoder.Decode(resp.Body)
	if err != nil {
		level.Error(log).Log("err", err, "query", qs)
		return nil, err
	}

	if len(warning) > 0 {
		level.Warn(log).Log("warnings", warning, "query", qs)
	}

	return vector, nil
}

func extractHeader(headers []*httpgrpc.Header, target string) string {
	for _, h := range headers {