opensource/grafana
1
0
Fork 0
mirror of https://github.com/grafana/grafana.git synced 2025-08-06 08:29:33 +08:00
Code Issues Packages Projects Releases Wiki Activity

Chore: Remove unused header params in prometheus request (#81684)

Browse Source 
Remove unused header params
This commit is contained in:
ismail simsek
2024-02-01 11:17:38 +01:00
committed by GitHub
parent fd54d25496
commit 4561863fca
1 changed files with 8 additions and 8 deletions
Download Patch File Download Diff File Expand all files Collapse all files

16
pkg/tsdb/prometheus/querydata/request.go
View File

@ -101,7 +101,7 @@ func (s *QueryData) Execute(ctx context.Context, req *backend.QueryDataRequest)
return &result, err return &result, err
} }
r := s.fetch(ctx, s.client, query, req.Headers) r := s.fetch(ctx, s.client, query)
if r == nil { if r == nil {
s.log.FromContext(ctx).Debug("Received nil response from runQuery", "query", query.Expr) s.log.FromContext(ctx).Debug("Received nil response from runQuery", "query", query.Expr)
continue continue
@ -112,7 +112,7 @@ func (s *QueryData) Execute(ctx context.Context, req *backend.QueryDataRequest)
return &result, nil return &result, nil
} }
func (s *QueryData) fetch(ctx context.Context, client *client.Client, q *models.Query, headers map[string]string) *backend.DataResponse { func (s *QueryData) fetch(ctx context.Context, client *client.Client, q *models.Query) *backend.DataResponse {
traceCtx, end := s.trace(ctx, q) traceCtx, end := s.trace(ctx, q)
defer end() defer end()
@ -125,14 +125,14 @@ func (s *QueryData) fetch(ctx context.Context, client *client.Client, q *models.
} }
if q.InstantQuery { if q.InstantQuery {
res := s.instantQuery(traceCtx, client, q, headers) res := s.instantQuery(traceCtx, client, q)
dr.Error = res.Error dr.Error = res.Error
dr.Frames = res.Frames dr.Frames = res.Frames
dr.Status = res.Status dr.Status = res.Status
} }
if q.RangeQuery { if q.RangeQuery {
res := s.rangeQuery(traceCtx, client, q, headers) res := s.rangeQuery(traceCtx, client, q)
if res.Error != nil { if res.Error != nil {
if dr.Error == nil { if dr.Error == nil {
dr.Error = res.Error dr.Error = res.Error
@ -147,7 +147,7 @@ func (s *QueryData) fetch(ctx context.Context, client *client.Client, q *models.
} }
if q.ExemplarQuery { if q.ExemplarQuery {
res := s.exemplarQuery(traceCtx, client, q, headers) res := s.exemplarQuery(traceCtx, client, q)
if res.Error != nil { if res.Error != nil {
// If exemplar query returns error, we want to only log it and // If exemplar query returns error, we want to only log it and
// continue with other results processing // continue with other results processing
@ -159,7 +159,7 @@ func (s *QueryData) fetch(ctx context.Context, client *client.Client, q *models.
return dr return dr
} }
func (s *QueryData) rangeQuery(ctx context.Context, c *client.Client, q *models.Query, headers map[string]string) backend.DataResponse { func (s *QueryData) rangeQuery(ctx context.Context, c *client.Client, q *models.Query) backend.DataResponse {
res, err := c.QueryRange(ctx, q) res, err := c.QueryRange(ctx, q)
if err != nil { if err != nil {
return backend.DataResponse{ return backend.DataResponse{
@ -178,7 +178,7 @@ func (s *QueryData) rangeQuery(ctx context.Context, c *client.Client, q *models.
return s.parseResponse(ctx, q, res) return s.parseResponse(ctx, q, res)
} }
func (s *QueryData) instantQuery(ctx context.Context, c *client.Client, q *models.Query, headers map[string]string) backend.DataResponse { func (s *QueryData) instantQuery(ctx context.Context, c *client.Client, q *models.Query) backend.DataResponse {
res, err := c.QueryInstant(ctx, q) res, err := c.QueryInstant(ctx, q)
if err != nil { if err != nil {
return backend.DataResponse{ return backend.DataResponse{
@ -204,7 +204,7 @@ func (s *QueryData) instantQuery(ctx context.Context, c *client.Client, q *model
return s.parseResponse(ctx, q, res) return s.parseResponse(ctx, q, res)
} }
func (s *QueryData) exemplarQuery(ctx context.Context, c *client.Client, q *models.Query, headers map[string]string) backend.DataResponse { func (s *QueryData) exemplarQuery(ctx context.Context, c *client.Client, q *models.Query) backend.DataResponse {
res, err := c.QueryExemplars(ctx, q) res, err := c.QueryExemplars(ctx, q)
if err != nil { if err != nil {
return backend.DataResponse{ return backend.DataResponse{