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

Update GetStatsAfterReset in stats_it_test.go

Browse Source
This commit is contained in:
TeoV
2017-09-27 14:06:12 +03:00
parent 9a36cb5bb5
commit b27e5038be
1 changed files with 43 additions and 29 deletions
Download Patch File Download Diff File Expand all files Collapse all files

72
apier/v1/stats_it_test.go
View File

@@ -77,8 +77,8 @@ var sTestsStatSV1 = []func(t *testing.T){
testV1STSRpcConn,
testV1STSFromFolder,
testV1STSGetStats,
testV1STSGetStatsAfterRestart,
testV1STSProcessEvent,
testV1STSGetStatsAfterRestart,
testV1STSSetStatQueueProfile,
testV1STSUpdateStatQueueProfile,
testV1STSRemoveStatQueueProfile,
@@ -168,34 +168,6 @@ func testV1STSGetStats(t *testing.T) {
}
}
func testV1STSGetStatsAfterRestart(t *testing.T) {
var reply []string
expectedIDs := []string{"STATS_1"}
//get stats before restart
if err := stsV1Rpc.Call("StatSV1.GetQueueIDs", "cgrates.org", &reply); err != nil {
t.Error(err)
} else if !reflect.DeepEqual(expectedIDs, reply) {
t.Errorf("expecting: %+v, received reply: %s", expectedIDs, reply)
}
if _, err := engine.StopStartEngine(stsV1CfgPath, statsDelay); err != nil {
t.Fatal(err)
}
var err error
stsV1Rpc, err = jsonrpc.Dial("tcp", stsV1Cfg.RPCJSONListen) // We connect over JSON so we can also troubleshoot if needed
if err != nil {
t.Fatal("Could not connect to rater: ", err.Error())
}
//get stats after restart
var reply2 []string
expectedIDs2 := []string{"STATS_1"}
if err := stsV1Rpc.Call("StatSV1.GetQueueIDs", "cgrates.org", &reply2); err != nil {
t.Error(err)
} else if !reflect.DeepEqual(expectedIDs2, reply2) {
t.Errorf("expecting: %+v, received reply: %s", expectedIDs2, reply2)
}
time.Sleep(time.Duration(1 * time.Second))
}
func testV1STSProcessEvent(t *testing.T) {
var reply string
ev1 := engine.StatEvent{
@@ -252,6 +224,48 @@ func testV1STSProcessEvent(t *testing.T) {
}
}
func testV1STSGetStatsAfterRestart(t *testing.T) {
expectedMetrics := map[string]string{
utils.MetaASR: "66.66667%",
utils.MetaACD: "1m30s",
utils.MetaACC: "61.5",
utils.MetaTCD: "3m0s",
utils.MetaTCC: "123",
utils.MetaPDD: "4s",
}
var metrics map[string]string
//get stats metrics before restart
if err := stsV1Rpc.Call("StatSV1.GetQueueStringMetrics", &utils.TenantID{Tenant: "cgrates.org", ID: "STATS_1"}, &metrics); err != nil {
t.Error(err)
} else if !reflect.DeepEqual(expectedMetrics, metrics) {
t.Errorf("expecting: %+v, received reply: %s", expectedMetrics, metrics)
}
if _, err := engine.StopStartEngine(stsV1CfgPath, statsDelay); err != nil {
t.Fatal(err)
}
var err error
stsV1Rpc, err = jsonrpc.Dial("tcp", stsV1Cfg.RPCJSONListen) // We connect over JSON so we can also troubleshoot if needed
if err != nil {
t.Fatal("Could not connect to rater: ", err.Error())
}
//get stats metrics after restart
expectedMetrics2 := map[string]string{
utils.MetaASR: "66.66667%",
utils.MetaACD: "1m30s",
utils.MetaACC: "61.5",
utils.MetaTCD: "3m0s",
utils.MetaTCC: "123",
utils.MetaPDD: "4s",
}
var metrics2 map[string]string
if err := stsV1Rpc.Call("StatSV1.GetQueueStringMetrics", &utils.TenantID{Tenant: "cgrates.org", ID: "STATS_1"}, &metrics2); err != nil {
t.Error(err)
} else if !reflect.DeepEqual(expectedMetrics2, metrics2) {
t.Errorf("expecting: %+v, received reply: %s", expectedMetrics2, metrics2)
}
time.Sleep(time.Duration(1 * time.Second))
}
func testV1STSSetStatQueueProfile(t *testing.T) {
var reply *engine.StatQueueProfile
if err := stsV1Rpc.Call("ApierV1.GetStatQueueProfile",