Updated connManager ApierS internal connection channel

This commit is contained in:
Trial97
2020-02-17 13:09:12 +02:00
committed by Dan Christian Bogos
parent 5618994ab1
commit dcd03d9fe3
3 changed files with 4 additions and 3 deletions

View File

@@ -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
- [SessionS] Add *cost flag for SessionSv1.ProcessEvent to calculate the rater cost
- [ConnManager] Added ApierSv2 as internal connection channel instead of ApierSv1

View File

@@ -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,

View File

@@ -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