GitHub-Proxy/signoz
1
0
Fork 0
mirror of https://git.mirrors.martin98.com/https://github.com/SigNoz/signoz synced 2025-09-23 09:03:13 +08:00
Code Issues Packages Projects Releases Wiki Activity

added ability to query tags with isnotnull operator

Browse Source
This commit is contained in:
Ankit Nayan 2021-05-06 17:35:29 +05:30
parent 0f891ccb26
commit 050b57c72b
1 changed files with 16 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

16
pkg/query-service/druidQuery/query.go
View File

@ -45,6 +45,12 @@ func buildFilters(queryParams *model.SpanSearchParams) (*godruid.Filter, error)
newFilter := godruid.FilterSelector("Name", queryParams.OperationName) newFilter := godruid.FilterSelector("Name", queryParams.OperationName)
filter = godruid.FilterAnd(filter, newFilter) filter = godruid.FilterAnd(filter, newFilter)
}
if len(queryParams.Kind) != 0 {
newFilter := godruid.FilterSelector("Kind", queryParams.Kind)
filter = godruid.FilterAnd(filter, newFilter)
} }
// zap.S().Debug("MinDuration: ", queryParams.MinDuration) // zap.S().Debug("MinDuration: ", queryParams.MinDuration)
@ -75,6 +81,8 @@ func buildFilters(queryParams *model.SpanSearchParams) (*godruid.Filter, error)
valuesFilter := godruid.FilterSearch("TagsValues", fmt.Sprintf("%s", item.Value)) valuesFilter := godruid.FilterSearch("TagsValues", fmt.Sprintf("%s", item.Value))
keysFilter := godruid.FilterSelector("TagsKeys", fmt.Sprintf("%s", item.Key)) keysFilter := godruid.FilterSelector("TagsKeys", fmt.Sprintf("%s", item.Key))
newFilter = godruid.FilterAnd(valuesFilter, keysFilter) newFilter = godruid.FilterAnd(valuesFilter, keysFilter)
} else if item.Operator == "isnotnull" {
newFilter = godruid.FilterSelector("TagsKeys", fmt.Sprintf("%s", item.Key))
} else { } else {
return nil, fmt.Errorf("Tag Operator %s not supported", item.Operator) return nil, fmt.Errorf("Tag Operator %s not supported", item.Operator)
} }
@ -110,6 +118,12 @@ func buildFiltersForSpansAggregates(queryParams *model.SpanSearchAggregatesParam
newFilter := godruid.FilterSelector("Name", queryParams.OperationName) newFilter := godruid.FilterSelector("Name", queryParams.OperationName)
filter = godruid.FilterAnd(filter, newFilter) filter = godruid.FilterAnd(filter, newFilter)
}
if len(queryParams.Kind) != 0 {
newFilter := godruid.FilterSelector("Kind", queryParams.Kind)
filter = godruid.FilterAnd(filter, newFilter)
} }
// zap.S().Debug("MinDuration: ", queryParams.MinDuration) // zap.S().Debug("MinDuration: ", queryParams.MinDuration)
@ -140,6 +154,8 @@ func buildFiltersForSpansAggregates(queryParams *model.SpanSearchAggregatesParam
valuesFilter := godruid.FilterSearch("TagsValues", fmt.Sprintf("%s", item.Value)) valuesFilter := godruid.FilterSearch("TagsValues", fmt.Sprintf("%s", item.Value))
keysFilter := godruid.FilterSelector("TagsKeys", fmt.Sprintf("%s", item.Key)) keysFilter := godruid.FilterSelector("TagsKeys", fmt.Sprintf("%s", item.Key))
newFilter = godruid.FilterAnd(valuesFilter, keysFilter) newFilter = godruid.FilterAnd(valuesFilter, keysFilter)
} else if item.Operator == "isnotnull" {
newFilter = godruid.FilterSelector("TagsKeys", fmt.Sprintf("%s", item.Key))
} else { } else {
return nil, fmt.Errorf("Tag Operator %s not supported", item.Operator) return nil, fmt.Errorf("Tag Operator %s not supported", item.Operator)
} }