diff --git a/config/cachecfg.go b/config/cachecfg.go index 83ce016db..015bf675c 100755 --- a/config/cachecfg.go +++ b/config/cachecfg.go @@ -118,9 +118,9 @@ const CGRATES_CFG_JSON_DISABLED_CACHE = ` "charger_filter_indexes" : {"limit": 0}, "dispatcher_filter_indexes" : {"limit": 0}, "dispatcher_routes": {"limit": 0}, - "diameter_messages": {"limit": 0}, - "rpc_responses": {"limit": 0}, - "closed_sessions": {"limit": 0}, + "diameter_messages": {"limit": -1, "ttl": "3h", "static_ttl": false}, // diameter messages caching + "rpc_responses": {"limit": 0, "ttl": "2s", "static_ttl": false}, // RPC responses caching + "closed_sessions": {"limit": -1, "ttl": "10s", "static_ttl": false}, // closed sessions cached for CDRs "load_ids": {"limit": 0}, }, diff --git a/services/cdrs_it_test.go b/services/cdrs_it_test.go index 545029444..d1a764ddd 100644 --- a/services/cdrs_it_test.go +++ b/services/cdrs_it_test.go @@ -67,7 +67,7 @@ func TestCdrsReload(t *testing.T) { srvMngr := servmanager.NewServiceManager(cfg, engineShutdown) db := NewDataDBService(cfg) chrS := NewChargerService(cfg, db, chS, filterSChan, server, nil, nil) - schS := NewSchedulerService(cfg, db, chS, server, make(chan rpcclient.RpcClientConnection, 1), nil) + schS := NewSchedulerService(cfg, db, chS, filterSChan, server, make(chan rpcclient.RpcClientConnection, 1), nil) tS := NewThresholdService(cfg, db, chS, filterSChan, server) ralS := NewRalService(cfg, db, nil, nil, chS, filterSChan, server, tS.GetIntenternalChan(), internalChan, cacheSChan, internalChan, internalChan, diff --git a/services/rals_it_test.go b/services/rals_it_test.go index 457c8ca14..941375321 100644 --- a/services/rals_it_test.go +++ b/services/rals_it_test.go @@ -65,7 +65,7 @@ func TestRalsReload(t *testing.T) { server := utils.NewServer() srvMngr := servmanager.NewServiceManager(cfg, engineShutdown) db := NewDataDBService(cfg) - schS := NewSchedulerService(cfg, db, chS, server, make(chan rpcclient.RpcClientConnection, 1), nil) + schS := NewSchedulerService(cfg, db, chS, filterSChan, server, make(chan rpcclient.RpcClientConnection, 1), nil) tS := NewThresholdService(cfg, db, chS, filterSChan, server) ralS := NewRalService(cfg, db, nil, nil, chS, filterSChan, server, tS.GetIntenternalChan(), internalChan, cacheSChan, internalChan, internalChan, diff --git a/services/schedulers_it_test.go b/services/schedulers_it_test.go index 0604b870c..7ea358f46 100644 --- a/services/schedulers_it_test.go +++ b/services/schedulers_it_test.go @@ -48,7 +48,7 @@ func TestSchedulerSReload(t *testing.T) { internalCdrSChan := make(chan rpcclient.RpcClientConnection, 1) internalCdrSChan <- nil db := NewDataDBService(cfg) - schS := NewSchedulerService(cfg, db, chS, server, internalCdrSChan, nil) + schS := NewSchedulerService(cfg, db, chS, filterSChan, server, internalCdrSChan, nil) srvMngr.AddServices(schS, NewLoaderService(cfg, db, filterSChan, server, nil, nil, engineShutdown), db) if err = srvMngr.StartServices(); err != nil { t.Error(err) diff --git a/services/sessions_it_test.go b/services/sessions_it_test.go index de2c4b479..2a08e6d0e 100644 --- a/services/sessions_it_test.go +++ b/services/sessions_it_test.go @@ -69,7 +69,7 @@ func TestSessionSReload(t *testing.T) { srvMngr := servmanager.NewServiceManager(cfg, engineShutdown) db := NewDataDBService(cfg) chrS := NewChargerService(cfg, db, chS, filterSChan, server, nil, nil) - schS := NewSchedulerService(cfg, db, chS, server, make(chan rpcclient.RpcClientConnection, 1), nil) + schS := NewSchedulerService(cfg, db, chS, filterSChan, server, make(chan rpcclient.RpcClientConnection, 1), nil) ralS := NewRalService(cfg, db, nil, nil, chS, filterSChan, server, /*tS*/ internalChan, internalChan, cacheSChan, internalChan, internalChan, internalChan, schS, engineShutdown)