diff --git a/apier/v1/apier.go b/apier/v1/apier.go index f7d3940f0..98669e987 100644 --- a/apier/v1/apier.go +++ b/apier/v1/apier.go @@ -929,6 +929,7 @@ func (self *ApierV1) FlushCache(args utils.AttrReloadCache, reply *string) (err flushCache(utils.CacheAttributeProfiles, args.AttributeProfileIDs) flushCache(utils.CacheChargerProfiles, args.ChargerProfileIDs) flushCache(utils.CacheDispatcherProfiles, args.DispatcherProfileIDs) + flushCache(utils.CacheDispatcherRoutes, args.DispatcherRoutesIDs) *reply = utils.OK return @@ -955,6 +956,7 @@ func (self *ApierV1) GetCacheStats(attrs utils.AttrCacheStats, reply *utils.Cach cs.AttributeProfiles = len(engine.Cache.GetItemIDs(utils.CacheAttributeProfiles, "")) cs.ChargerProfiles = len(engine.Cache.GetItemIDs(utils.CacheChargerProfiles, "")) cs.DispatcherProfiles = len(engine.Cache.GetItemIDs(utils.CacheDispatcherProfiles, "")) + cs.DispatcherRoutes = len(engine.Cache.GetItemIDs(utils.CacheDispatcherRoutes, "")) *reply = *cs return nil @@ -1097,7 +1099,13 @@ func (v1 *ApierV1) GetCacheKeys(args utils.ArgsCacheKeys, reply *utils.ArgsCache if args.DispatcherProfileIDs != nil { ids := getCacheKeys(utils.CacheDispatcherProfiles, args.DispatcherProfileIDs, args.Paginator) if len(ids) != 0 { - reply.ChargerProfileIDs = &ids + reply.DispatcherProfileIDs = &ids + } + } + if args.DispatcherRoutesIDs != nil { + ids := getCacheKeys(utils.CacheDispatcherRoutes, args.DispatcherRoutesIDs, args.Paginator) + if len(ids) != 0 { + reply.DispatcherRoutesIDs = &ids } } diff --git a/utils/apitpdata.go b/utils/apitpdata.go index 83f90aec8..12677d9d3 100755 --- a/utils/apitpdata.go +++ b/utils/apitpdata.go @@ -473,6 +473,7 @@ type ArgsCache struct { AttributeProfileIDs *[]string ChargerProfileIDs *[]string DispatcherProfileIDs *[]string + DispatcherRoutesIDs *[]string } // Data used to do remote cache reloads via api @@ -512,6 +513,7 @@ type CacheStats struct { AttributeProfiles int ChargerProfiles int DispatcherProfiles int + DispatcherRoutes int } type AttrExpFileCdrs struct {