Make empty connection from apier to caches

This commit is contained in:
TeoV
2019-03-21 11:09:41 +02:00
committed by Dan Christian Bogos
parent dac77f99ea
commit 8faf5cd6a9
5 changed files with 5 additions and 17 deletions

View File

@@ -751,9 +751,7 @@ const CGRATES_CFG_JSON = `
"apier": {
"caches_conns":[ // connections to CacheS for reloads
{"address": "127.0.0.1:2012", "transport": "*json"}
],
"caches_conns":[], // connections to CacheS for reloads
"default_cache":"", // default actions to do when caching items(""-default caching by data manager, "*none"-disable caching)
},

View File

@@ -1495,12 +1495,7 @@ func TestDfAnalyzerCfg(t *testing.T) {
func TestDfApierCfg(t *testing.T) {
eCfg := &ApierJsonCfg{
Caches_conns: &[]*HaPoolJsonCfg{
{
Address: utils.StringPointer("127.0.0.1:2012"),
Transport: utils.StringPointer(utils.MetaJSONrpc),
},
},
Caches_conns: &[]*HaPoolJsonCfg{},
Default_cache: utils.StringPointer(utils.EmptyString),
}
if cfg, err := dfCgrJsonCfg.ApierCfgJson(); err != nil {

View File

@@ -1703,12 +1703,7 @@ func TestNewCGRConfigFromPathNotFound(t *testing.T) {
func TestCgrCfgJSONDefaultApierCfg(t *testing.T) {
aCfg := &ApierCfg{
CachesConns: []*HaPoolConfig{
{
Address: "127.0.0.1:2012",
Transport: utils.MetaJSONrpc,
},
},
CachesConns: []*HaPoolConfig{},
DefaultCache: utils.EmptyString,
}
if !reflect.DeepEqual(cgrCfg.apier, aCfg) {

View File

@@ -301,7 +301,7 @@ func testAttrITMigrateAndMove(t *testing.T) {
t.Errorf("Expecting: %+v, received: %+v", utils.ToJSON(attrPrf), utils.ToJSON(result))
}
case utils.Move:
if err := attrMigrator.dmIN.DataManager().SetAttributeProfile(attrPrf, false); err != nil {
if err := attrMigrator.dmIN.DataManager().SetAttributeProfile(attrPrf, false, false); err != nil {
t.Error(err)
}
currentVersion := engine.CurrentDataDBVersions()

View File

@@ -188,7 +188,7 @@ func testFltrITMigrateAndMove(t *testing.T) {
if err := fltrMigrator.dmIN.DataManager().SetFilter(Filters); err != nil {
t.Error("Error when setting v1 Filters ", err.Error())
}
if err := fltrMigrator.dmIN.DataManager().SetAttributeProfile(attrProf, false); err != nil {
if err := fltrMigrator.dmIN.DataManager().SetAttributeProfile(attrProf, false, false); err != nil {
t.Error("Error when setting attribute profile for v1 Filters ", err.Error())
}
currentVersion := engine.Versions{utils.RQF: 1}