mirror of
https://github.com/cgrates/cgrates.git
synced 2026-02-11 18:16:24 +05:00
cgr-loader populate Transport when -caches_address is present
This commit is contained in:
committed by
Dan Christian Bogos
parent
ada94f1920
commit
f1889b0a88
@@ -84,7 +84,7 @@ var (
|
||||
|
||||
fromStorDB = flag.Bool("from_stordb", false, "Load the tariff plan from storDb to dataDb")
|
||||
toStorDB = flag.Bool("to_stordb", false, "Import the tariff plan from files to storDb")
|
||||
rpcEncoding = flag.String("rpc_encoding", utils.MetaJSONrpc, "RPC encoding used <gob|json>")
|
||||
rpcEncoding = flag.String("rpc_encoding", utils.MetaJSONrpc, "RPC encoding used <*gob|*json>")
|
||||
cacheSAddress = flag.String("caches_address", dfltCfg.LoaderCgrCfg().CachesConns[0].Address,
|
||||
"CacheS component to contact for cache reloads, empty to disable automatic cache reloads")
|
||||
schedulerAddress = flag.String("scheduler_address", dfltCfg.LoaderCgrCfg().SchedulerConns[0].Address, "")
|
||||
@@ -192,7 +192,10 @@ func main() {
|
||||
ldrCfg.LoaderCgrCfg().CachesConns = make([]*config.HaPoolConfig, 0)
|
||||
if *cacheSAddress != "" {
|
||||
ldrCfg.LoaderCgrCfg().CachesConns = append(ldrCfg.LoaderCgrCfg().CachesConns,
|
||||
&config.HaPoolConfig{Address: *cacheSAddress})
|
||||
&config.HaPoolConfig{
|
||||
Address: *cacheSAddress,
|
||||
Transport: *rpcEncoding,
|
||||
})
|
||||
}
|
||||
}
|
||||
|
||||
|
||||
Reference in New Issue
Block a user