mirror of
https://github.com/grafana/grafana.git
synced 2025-02-25 18:55:37 -06:00
Prometheus: Add error source to differentiate errors for api server work (#95999)
add error source to differentiate errors for api server work
This commit is contained in:
parent
b2af163dc5
commit
b9b5445090
@ -235,8 +235,9 @@ func (s *QueryData) rangeQuery(ctx context.Context, c *client.Client, q *models.
|
||||
res, err := c.QueryRange(ctx, q)
|
||||
if err != nil {
|
||||
return backend.DataResponse{
|
||||
Error: err,
|
||||
Status: backend.StatusBadGateway,
|
||||
Error: err,
|
||||
Status: backend.StatusBadGateway,
|
||||
ErrorSource: backend.ErrorSourceDownstream,
|
||||
}
|
||||
}
|
||||
|
||||
@ -254,15 +255,17 @@ func (s *QueryData) instantQuery(ctx context.Context, c *client.Client, q *model
|
||||
res, err := c.QueryInstant(ctx, q)
|
||||
if err != nil {
|
||||
return backend.DataResponse{
|
||||
Error: err,
|
||||
Status: backend.StatusBadGateway,
|
||||
Error: err,
|
||||
Status: backend.StatusBadGateway,
|
||||
ErrorSource: backend.ErrorSourceDownstream,
|
||||
}
|
||||
}
|
||||
|
||||
// This is only for health check fall back scenario
|
||||
if res.StatusCode != 200 && q.RefId == "__healthcheck__" {
|
||||
return backend.DataResponse{
|
||||
Error: errors.New(res.Status),
|
||||
Error: errors.New(res.Status),
|
||||
ErrorSource: backend.ErrorSourceDownstream,
|
||||
}
|
||||
}
|
||||
|
||||
@ -280,7 +283,8 @@ func (s *QueryData) exemplarQuery(ctx context.Context, c *client.Client, q *mode
|
||||
res, err := c.QueryExemplars(ctx, q)
|
||||
if err != nil {
|
||||
return backend.DataResponse{
|
||||
Error: err,
|
||||
Error: err,
|
||||
ErrorSource: backend.ErrorSourceDownstream,
|
||||
}
|
||||
}
|
||||
|
||||
|
Loading…
Reference in New Issue
Block a user