From f1889b0a88944cb9ff58ff24153506f8e82ce82a Mon Sep 17 00:00:00 2001 From: Trial97 Date: Mon, 26 Nov 2018 13:19:58 +0200 Subject: [PATCH] cgr-loader populate Transport when -caches_address is present --- cmd/cgr-loader/cgr-loader.go | 7 +++++-- 1 file changed, 5 insertions(+), 2 deletions(-) diff --git a/cmd/cgr-loader/cgr-loader.go b/cmd/cgr-loader/cgr-loader.go index e02eb762b..21a815922 100755 --- a/cmd/cgr-loader/cgr-loader.go +++ b/cmd/cgr-loader/cgr-loader.go @@ -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 ") + 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, + }) } }