uppal/cgrates
1
0
Fork 1
mirror of https://github.com/cgrates/cgrates.git synced 2026-02-16 21:59:53 +05:00
Code Issues Packages Projects Releases Wiki Activity

Improved stats

Browse Source
This commit is contained in:
porosnicuadrian
2022-05-04 11:09:53 +03:00
committed by Dan Christian Bogos
parent 5537e8993d
commit d3580092ed
5 changed files with 7 additions and 9 deletions
Download Patch File Download Diff File Expand all files Collapse all files

5
engine/libstats.go
View File

@@ -318,9 +318,8 @@ func (sq *StatQueue) addStatEvent(ctx *context.Context, tnt, evID string, filter
continue
}
// in case of # metrics type
metricSplit := strings.Split(metricCfg.MetricID, utils.HashtagSep)
if err = sq.SQMetrics[metricSplit[0]].AddEvent(evID, dDP); err != nil {
utils.Logger.Warning(fmt.Sprintf("<StatQueue>: metric: %s, add eventID: %s, error: %s", metricSplit[0],
if err = sq.SQMetrics[metricCfg.MetricID].AddEvent(evID, dDP); err != nil {
utils.Logger.Warning(fmt.Sprintf("<StatQueue>: metric: %s, add eventID: %s, error: %s", metricCfg.MetricID,
evID, err.Error()))
return
}

4
engine/stats_test.go
View File

@@ -239,7 +239,7 @@ func prepareStatsData(t *testing.T, dm *DataManager) {
if err != nil {
t.Fatal(err)
}
statQueue.SQMetrics[utils.MetaSum] = statSum
statQueue.SQMetrics["*sum#~*req.Usage"] = statSum
dm.SetStatQueue(context.Background(), statQueue)
}
//Test each statQueueProfile from cache
@@ -476,7 +476,7 @@ func TestStatQueuesV1ProcessEvent(t *testing.T) {
if err != nil {
t.Fatal(err)
}
sq := &StatQueue{Tenant: "cgrates.org", ID: "StatQueueProfile3", sqPrfl: sqPrf, SQMetrics: map[string]StatMetric{utils.MetaSum: statSum}}
sq := &StatQueue{Tenant: "cgrates.org", ID: "StatQueueProfile3", sqPrfl: sqPrf, SQMetrics: map[string]StatMetric{"*sum#~*req.Usage": statSum}}
if err := dmSTS.SetStatQueueProfile(context.TODO(), sqPrf, true); err != nil {
t.Error(err)
}

4
general_tests/all_cfg_rld_it_test.go
View File

File diff suppressed because one or more lines are too long

2
general_tests/all_sections_cfg_rld_it_test.go
View File

File diff suppressed because one or more lines are too long

1
general_tests/cdrs_it_test.go
View File

@@ -134,7 +134,6 @@ func testCDRsLoadTariffPlanFromFolder(t *testing.T) {
} else if rpl != utils.OK {
t.Error("Unexpected reply returned:", rpl)
}
time.Sleep(time.Duration(*waitRater) * time.Millisecond) // Give time for scheduler to execute topups
var resp string
if err := cdrsRpc.Call(context.Background(), utils.AdminSv1RemoveChargerProfile,
&utils.TenantID{Tenant: "cgrates.org", ID: "SupplierCharges"}, &resp); err != nil {