uppal/cgrates
1
0
Fork 1
mirror of https://github.com/cgrates/cgrates.git synced 2026-02-22 15:48:44 +05:00
Code Issues Packages Projects Releases Wiki Activity

Increase analyzer search hits maximum size

Browse Source
This commit is contained in:
ionutboangiu
2022-09-13 18:29:41 +03:00
committed by Dan Christian Bogos
parent eb594c5f7e
commit 5bf67119ad
2 changed files with 17 additions and 9 deletions
Download Patch File Download Diff File Expand all files Collapse all files

2
analyzers/analyzers.go
View File

@@ -154,7 +154,7 @@ func (aS *AnalyzerS) V1StringQuery(ctx *context.Context, args *QueryArgs, reply
} else {
q = bleve.NewQueryStringQuery(args.HeaderFilters)
}
s := bleve.NewSearchRequest(q)
s := bleve.NewSearchRequestOptions(q, utils.AbsoluteMaxInt, 0, false)
s.Fields = []string{utils.Meta} // return all fields
searchResults, err := aS.db.SearchInContext(ctx, s)
if err != nil {

24
general_tests/analyzers_doc_it_test.go
View File

@@ -67,7 +67,7 @@ var (
// make queries to the AnalyzerS db using only HeaderFilters
testAnzDocQueryWithHeaderFilters,
// make queries to the AnalyzerS db using only ContentFilters
// testAnzDocQueryWithContentFiltersFilters,
testAnzDocQueryWithContentFiltersFilters,
// make queries to the AnalyzerS db using a combination of both types of filters
testAnzDocQuery,
testAnzDocKillEngine,
@@ -133,7 +133,7 @@ func testAnzDocCoreSStatus(t *testing.T) {
func testPopulateTimeVariable(t *testing.T) {
time.Sleep(time.Second)
timeVar = time.Now().Format("2006-01-02T15:04:05Z07:00")
timeVar = time.Now().UTC().Format("2006-01-02T15:04:05Z07:00")
}
func testAnzDocSetAttributeProfiles(t *testing.T) {
@@ -502,6 +502,16 @@ func testAnzDocQueryWithHeaderFilters(t *testing.T) {
t.Errorf("Unexpected result: %s", utils.ToJSON(result))
}
// Query results for all the request methods except CacheSv1.ReloadCache using HeaderFilters
if err := anzDocRPC.Call(context.Background(), utils.AnalyzerSv1StringQuery, &analyzers.QueryArgs{
HeaderFilters: `-RequestMethod:"CacheSv1.ReloadCache"`,
ContentFilters: []string{},
}, &result); err != nil {
t.Error(err)
} else if len(result) != 11 {
t.Errorf("Unexpected result: %s", utils.ToJSON(result))
}
// Query all results for the requests made to the AdminS service using regular expressions
if err := anzDocRPC.Call(context.Background(), utils.AnalyzerSv1StringQuery, &analyzers.QueryArgs{
HeaderFilters: `+RequestMethod:"/AdminSv1.*/"`,
@@ -526,12 +536,11 @@ func testAnzDocQueryWithHeaderFilters(t *testing.T) {
// Query results for API calls with RequestID smaller or equal to 2
if err := anzDocRPC.Call(context.Background(), utils.AnalyzerSv1StringQuery, &analyzers.QueryArgs{
HeaderFilters: `+RequestID:<=2`,
HeaderFilters: `+RequestID:<=2 -RequestMethod:"CacheSv1.ReloadCache"`,
ContentFilters: []string{},
}, &result); err != nil {
t.Error(err)
} else if len(result) != 7 {
fmt.Println(len(result))
} else if len(result) != 2 {
t.Errorf("Unexpected result: %s", utils.ToJSON(result))
}
}
@@ -624,11 +633,10 @@ func testAnzDocQueryWithContentFiltersFilters(t *testing.T) {
// Query results for API calls with with an execution duration longer than 30ms
if err := anzDocRPC.Call(context.Background(), utils.AnalyzerSv1StringQuery, &analyzers.QueryArgs{
HeaderFilters: "",
ContentFilters: []string{"*gt:~*hdr.RequestDuration:30ms"},
ContentFilters: []string{"*gt:~*hdr.RequestDuration:50ms"},
}, &result); err != nil {
t.Error(err)
} else if len(result) != 7 {
fmt.Println(len(result))
} else if len(result) != 1 {
t.Errorf("Unexpected result: %s", utils.ToJSON(result))
}
}