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

Added cache dispatcher test

Browse Source
This commit is contained in:
Tripon Alexandru-Ionut
2019-04-11 14:54:51 +03:00
committed by Dan Christian Bogos
parent a447590aab
commit 299c659e13
1 changed files with 21 additions and 0 deletions
Download Patch File Download Diff File Expand all files Collapse all files

21
apier/v1/dispatcher_it_test.go
View File

@@ -31,6 +31,7 @@ import (
"github.com/cgrates/cgrates/config"
"github.com/cgrates/cgrates/engine"
"github.com/cgrates/cgrates/utils"
"github.com/cgrates/ltcache"
)
var (
@@ -52,11 +53,13 @@ var sTestsDispatcher = []func(t *testing.T){
testDispatcherSSetDispatcherProfile,
testDispatcherSGetDispatcherProfileIDs,
testDispatcherSUpdateDispatcherProfile,
testDispatcherSGetDispatcherProfileCache,
testDispatcherSRemDispatcherProfile,
testDispatcherSSetDispatcherHost,
testDispatcherSGetDispatcherHostIDs,
testDispatcherSUpdateDispatcherHost,
testDispatcherSGetDispatcherHostCache,
testDispatcherSRemDispatcherHost,
testDispatcherSKillEngine,
@@ -196,6 +199,15 @@ func testDispatcherSUpdateDispatcherProfile(t *testing.T) {
}
}
func testDispatcherSGetDispatcherProfileCache(t *testing.T) {
var rcvStats map[string]*ltcache.CacheStats
if err := dispatcherRPC.Call(utils.CacheSv1GetCacheStats, nil, &rcvStats); err != nil {
t.Error(err)
} else if rcvStats[utils.CacheDispatcherProfiles].Items != 1 {
t.Errorf("Expecting: 1 DispatcherProfiles, received: %+v", rcvStats[utils.CacheDispatcherProfiles])
}
}
func testDispatcherSRemDispatcherProfile(t *testing.T) {
var result string
if err := dispatcherRPC.Call(utils.ApierV1RemoveDispatcherProfile,
@@ -302,6 +314,15 @@ func testDispatcherSUpdateDispatcherHost(t *testing.T) {
}
}
func testDispatcherSGetDispatcherHostCache(t *testing.T) {
var rcvStats map[string]*ltcache.CacheStats
if err := dispatcherRPC.Call(utils.CacheSv1GetCacheStats, nil, &rcvStats); err != nil {
t.Error(err)
} else if rcvStats[utils.CacheDispatcherHosts].Items != 0 {
t.Errorf("Expecting: 0 DispatcherProfiles, received: %+v", rcvStats[utils.CacheDispatcherProfiles])
}
}
func testDispatcherSRemDispatcherHost(t *testing.T) {
var result string
if err := dispatcherRPC.Call(utils.ApierV1RemoveDispatcherHost,