Skip to content
This repository was archived by the owner on Aug 23, 2023. It is now read-only.
This commit does not belong to any branch on this repository, and may belong to a fork outside of the repository.

Commit 3738209

Browse files
committedJul 16, 2019
cleanup
remove dead code and add comments
1 parent 5dc9934 commit 3738209

File tree

3 files changed

+7
-18
lines changed

3 files changed

+7
-18
lines changed
 

‎expr/tagquery/expression.go

-15
Original file line numberDiff line numberDiff line change
@@ -371,21 +371,6 @@ func ExpressionsAreEqual(expr1, expr2 Expression) bool {
371371
// MetricDefinitionFilter takes a metric name together with its tags and returns a FilterDecision
372372
type MetricDefinitionFilter func(name string, tags []string) FilterDecision
373373

374-
type MetricDefinitionFilters []MetricDefinitionFilter
375-
376-
func (m MetricDefinitionFilters) Filter(name string, tags []string) FilterDecision {
377-
for i := range m {
378-
decision := m[i](name, tags)
379-
if decision == Fail {
380-
return Fail
381-
} else if decision == Pass {
382-
return Pass
383-
}
384-
}
385-
386-
return None
387-
}
388-
389374
type FilterDecision uint8
390375

391376
const (

‎expr/tagquery/query.go

+6-2
Original file line numberDiff line numberDiff line change
@@ -79,8 +79,12 @@ func NewQuery(expressions Expressions, from int64) (Query, error) {
7979
return q, nil
8080
}
8181

82-
func (q *Query) GetMetricDefinitionFilters() (MetricDefinitionFilters, []FilterDecision) {
83-
var filters MetricDefinitionFilters
82+
// GetMetricDefinitionFilters returns all the metric definition filters associated with this
83+
// query, together with their according default decision
84+
// The returned filters get generated from the query expressions, excluding the one which has
85+
// been dedicated to be the initial expression (marked via the .startWith index)
86+
func (q *Query) GetMetricDefinitionFilters() ([]MetricDefinitionFilter, []FilterDecision) {
87+
var filters []MetricDefinitionFilter
8488
var defaultDecisions []FilterDecision
8589
for i := range q.Expressions {
8690
// the one we start with does not need to be added to the filters,

‎idx/memory/tag_query.go

+1-1
Original file line numberDiff line numberDiff line change
@@ -21,7 +21,7 @@ type TagQueryContext struct {
2121
wg sync.WaitGroup
2222

2323
query tagquery.Query
24-
filters tagquery.MetricDefinitionFilters
24+
filters []tagquery.MetricDefinitionFilter
2525
defaultDecisions []tagquery.FilterDecision
2626

2727
index TagIndex // the tag index, hierarchy of tags & values, set by Run()/RunGetTags()

0 commit comments

Comments
 (0)
This repository has been archived.