diff --git a/Changelog.tmp b/Changelog.tmp index 44e623635..9917aa485 100644 --- a/Changelog.tmp +++ b/Changelog.tmp @@ -1,4 +1,5 @@ - [FilterS] Renamed rals_conns to apiers_conns - [FilterS] Updated *destination filter to get ReverseDestination form API - [SessionS] Added check for missing CGRevent -- [SessionS] Add *cost flag for SessionSv1.ProcessEvent to calculate the rater cost \ No newline at end of file +- [SessionS] Add *cost flag for SessionSv1.ProcessEvent to calculate the rater cost +- [ConnManager] Added ApierSv2 as internal connection channel instead of ApierSv1 diff --git a/cmd/cgr-engine/cgr-engine.go b/cmd/cgr-engine/cgr-engine.go index 150a3b9ba..813ce9f24 100644 --- a/cmd/cgr-engine/cgr-engine.go +++ b/cmd/cgr-engine/cgr-engine.go @@ -417,7 +417,7 @@ func main() { // because we need to pass the connection to it connManager := engine.NewConnManager(cfg, map[string]chan rpcclient.ClientConnector{ utils.ConcatenatedKey(utils.MetaInternal, utils.MetaAnalyzer): internalAnalyzerSChan, - utils.ConcatenatedKey(utils.MetaInternal, utils.MetaApier): internalAPIerSv1Chan, + utils.ConcatenatedKey(utils.MetaInternal, utils.MetaApier): internalAPIerSv2Chan, utils.ConcatenatedKey(utils.MetaInternal, utils.MetaAttributes): internalAttributeSChan, utils.ConcatenatedKey(utils.MetaInternal, utils.MetaCaches): internalCacheSChan, utils.ConcatenatedKey(utils.MetaInternal, utils.MetaCDRs): internalCDRServerChan, diff --git a/engine/filters.go b/engine/filters.go index 487158e6a..3eced14df 100644 --- a/engine/filters.go +++ b/engine/filters.go @@ -444,7 +444,7 @@ func (fS *FilterS) getFieldNameDataProvider(initialDP config.DataProvider, if len(splitFldName) != 3 { return nil, fmt.Errorf("invalid fieldname <%s>", fieldName) } - var account *Account + var account Account if err = fS.connMgr.Call(fS.cfg.FilterSCfg().ApierSConns, nil, utils.APIerSv2GetAccount, &utils.AttrGetAccount{Tenant: tenant, Account: splitFldName[1]}, &account); err != nil { return