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

Add test for StatSv1.GetFloatMetrics

Browse Source
This commit is contained in:
TeoV
2019-04-11 15:25:33 +03:00
committed by Dan Christian Bogos
parent fccec58b88
commit e1adda4508
1 changed files with 36 additions and 0 deletions
Download Patch File Download Diff File Expand all files Collapse all files

36
apier/v1/stats_it_test.go
View File

@@ -204,6 +204,25 @@ func testV1STSProcessEvent(t *testing.T) {
t.Errorf("expecting: %+v, received reply: %s", expectedMetrics, metrics)
}
//process with one event (should be N/A becaus MinItems is 2)
expectedFloatMetrics := map[string]float64{
utils.MetaASR: -1.0,
utils.MetaACD: -1.0,
utils.MetaTCC: -1.0,
utils.MetaTCD: -1.0,
utils.MetaACC: -1.0,
utils.MetaPDD: -1.0,
utils.StatsJoin(utils.MetaSum, utils.Usage): -1.0,
utils.StatsJoin(utils.MetaAverage, utils.Usage): -1.0,
}
var floatMetrics map[string]float64
if err := stsV1Rpc.Call(utils.StatSv1GetQueueFloatMetrics,
&utils.TenantID{Tenant: "cgrates.org", ID: "Stats1"}, &floatMetrics); err != nil {
t.Error(err)
} else if !reflect.DeepEqual(expectedFloatMetrics, floatMetrics) {
t.Errorf("expecting: %+v, received reply: %+v", expectedFloatMetrics, floatMetrics)
}
args2 := engine.StatsArgsProcessEvent{
CGREvent: utils.CGREvent{
Tenant: "cgrates.org",
@@ -249,6 +268,23 @@ func testV1STSProcessEvent(t *testing.T) {
t.Errorf("expecting: %+v, received reply: %s", expectedMetrics2, metrics2)
}
expectedFloatMetrics2 := map[string]float64{
utils.MetaASR: 66.66667,
utils.MetaACD: 60,
utils.MetaTCC: 135.1,
utils.MetaTCD: 180,
utils.MetaACC: 45.03333,
utils.MetaPDD: -1.0,
utils.StatsJoin(utils.MetaSum, utils.Usage): 180000000000,
utils.StatsJoin(utils.MetaAverage, utils.Usage): 60000000000,
}
var floatMetrics2 map[string]float64
if err := stsV1Rpc.Call(utils.StatSv1GetQueueFloatMetrics, &utils.TenantID{Tenant: "cgrates.org", ID: "Stats1"}, &floatMetrics2); err != nil {
t.Error(err)
} else if !reflect.DeepEqual(expectedFloatMetrics2, floatMetrics2) {
t.Errorf("expecting: %+v, received reply: %+v", expectedFloatMetrics2, floatMetrics2)
}
}
func testV1STSGetStatsAfterRestart(t *testing.T) {