From 4d90083da25ffeccea78fb8b617a500be7da41b8 Mon Sep 17 00:00:00 2001 From: Trial97 Date: Thu, 6 May 2021 13:03:50 +0300 Subject: [PATCH] Added Resource,Threshold and Stats ids to TPReader cache reload --- engine/tpreader.go | 18 ++++++++++++++++++ 1 file changed, 18 insertions(+) diff --git a/engine/tpreader.go b/engine/tpreader.go index 3b9ef33bb..d4372cfc5 100644 --- a/engine/tpreader.go +++ b/engine/tpreader.go @@ -839,6 +839,24 @@ func (tpr *TpReader) ShowStatistics() { // GetLoadedIds returns the identities loaded for a specific category, useful for cache reloads func (tpr *TpReader) GetLoadedIds(categ string) ([]string, error) { switch categ { + case utils.ResourcesPrefix: + keys := make([]string, len(tpr.resources)) + for i, k := range tpr.resources { + keys[i] = k.TenantID() + } + return keys, nil + case utils.StatQueuePrefix: + keys := make([]string, len(tpr.statQueues)) + for i, k := range tpr.statQueues { + keys[i] = k.TenantID() + } + return keys, nil + case utils.ThresholdPrefix: + keys := make([]string, len(tpr.thresholds)) + for i, k := range tpr.thresholds { + keys[i] = k.TenantID() + } + return keys, nil case utils.DestinationPrefix: keys := make([]string, len(tpr.destinations)) i := 0