uppal/cgrates
1
0
Fork 1
mirror of https://github.com/cgrates/cgrates.git synced 2026-02-11 10:06:24 +05:00
Code Issues Packages Projects Releases Wiki Activity

Integration test for scheduleAutomaticQueries && api for scheduled trends

Browse Source
This commit is contained in:
gezimbll
2024-10-07 08:55:02 +02:00
committed by Dan Christian Bogos
parent 9c05a5817e
commit e518e7b913
17 changed files with 559 additions and 68 deletions
Download Patch File Download Diff File Expand all files Collapse all files

7
services/trends.go
View File

@@ -76,13 +76,14 @@ func (trs *TrendService) Start() error {
filterS := <-trs.filterSChan
trs.filterSChan <- filterS
dbchan := trs.dm.GetDMChan()
dm := <-dbchan
dbchan <- dm
datadb := <-dbchan
dbchan <- datadb
utils.Logger.Info(fmt.Sprintf("<%s> starting <%s> subsystem",
utils.CoreS, utils.TrendS))
trs.Lock()
defer trs.Unlock()
trs.trs = engine.NewTrendS(dm, trs.connMgr, filterS, trs.cfg)
trs.trs = engine.NewTrendS(datadb, trs.connMgr, filterS, trs.cfg)
if err := trs.trs.StartTrendS(); err != nil {
return err
}