mudhorn/prometheus
1
0
Fork 0
mirror of https://github.com/prometheus/prometheus.git synced 2025-03-05 20:59:13 -08:00
Code Issues Actions 4 Packages Projects Releases Wiki Activity

Set span status on error

Browse source 
Signed-off-by: Arve Knudsen <arve.knudsen@gmail.com>
This commit is contained in:
Arve Knudsen 2023-10-31 08:36:10 +01:00
parent 7c313be3b5
commit 403abaee79
1 changed files with 9 additions and 2 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

11
tsdb/postings_for_matchers_cache.go
View file

@ -10,6 +10,7 @@ import (
"github.com/DmitriyVTitov/size"
"go.opentelemetry.io/otel"
"go.opentelemetry.io/otel/attribute"
"go.opentelemetry.io/otel/codes"
"go.opentelemetry.io/otel/trace"
"github.com/prometheus/prometheus/model/labels"
@ -86,14 +87,20 @@ func (c *PostingsForMatchersCache) PostingsForMatchers(ctx context.Context, ix I
if !concurrent && !c.force {
span.AddEvent("cache not used")
p, err := c.postingsForMatchers(ctx, ix, ms...)
span.RecordError(err)
if err != nil {
span.SetStatus(codes.Error, "getting postings for matchers without cache failed")
span.RecordError(err)
}
return p, err
}
span.AddEvent("using cache")
c.expire()
p, err := c.postingsForMatchersPromise(ctx, ix, ms)(ctx)
span.RecordError(err)
if err != nil {
span.SetStatus(codes.Error, "getting postings for matchers with cache failed")
span.RecordError(err)
}
return p, err
}