Added Dispatcher Route to GetCahceKeys

This commit is contained in:
Trial97
2019-02-27 09:58:17 +02:00
committed by Dan Christian Bogos
parent e6a3de113e
commit b384e23079
2 changed files with 11 additions and 1 deletions

View File

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

View File

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