mirror of
https://github.com/prometheus/prometheus.git
synced 2025-03-05 20:59:13 -08:00
Fix dedupelabels
Signed-off-by: Filip Petkovski <filip.petkovsky@gmail.com>
This commit is contained in:
parent
355a84ad4c
commit
de887c5fe1
|
@ -63,7 +63,7 @@ func (r *ruleEngine) NewScrapeBatch() Batch {
|
||||||
func (r *ruleEngine) EvaluateRules(b Batch, ts time.Time, sampleMutator labelsMutator) ([]Sample, error) {
|
func (r *ruleEngine) EvaluateRules(b Batch, ts time.Time, sampleMutator labelsMutator) ([]Sample, error) {
|
||||||
var (
|
var (
|
||||||
result []Sample
|
result []Sample
|
||||||
builder labels.ScratchBuilder
|
builder = labels.NewScratchBuilder(0)
|
||||||
)
|
)
|
||||||
for _, rule := range r.rules {
|
for _, rule := range r.rules {
|
||||||
queryable := storage.QueryableFunc(func(_, _ int64) (storage.Querier, error) {
|
queryable := storage.QueryableFunc(func(_, _ int64) (storage.Querier, error) {
|
||||||
|
|
|
@ -5205,7 +5205,13 @@ metric{l1="1", l2="2"} 5`,
|
||||||
require.NoError(t, err)
|
require.NoError(t, err)
|
||||||
|
|
||||||
require.NoError(t, slApp.Commit())
|
require.NoError(t, slApp.Commit())
|
||||||
require.Equal(t, test.expectedFloats, app.resultFloats)
|
require.Len(t, app.resultFloats, len(test.expectedFloats))
|
||||||
|
for i := range app.resultFloats {
|
||||||
|
expected, actual := test.expectedFloats[i], app.resultFloats[i]
|
||||||
|
require.Equal(t, expected.metric.String(), actual.metric.String())
|
||||||
|
require.Equal(t, expected.t, actual.t)
|
||||||
|
require.Equal(t, expected.f, actual.f)
|
||||||
|
}
|
||||||
})
|
})
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|
Loading…
Reference in a new issue