add a method to completely flush the whole cache

Author: replay

api/ccache.go

@@ -25,17 +25,28 @@ func (s *Server) ccacheDelete(ctx *middleware.Context, req models.CCacheDelete)
 		}
 	}
 
+	fullFlush := false
 	for _, pattern := range req.Patterns {
-		nodes, err := s.MetricIndex.Find(req.OrgId, pattern, 0)
-		if err != nil {
-			res.Errors += 1
-			code = 500
-		} else {
-			for _, node := range nodes {
-				for _, def := range node.Defs {
-					delResult := s.Cache.DelMetric(def.Id)
-					res.DeletedSeries += delResult.Series
-					res.DeletedArchives += delResult.Archives
+		if pattern == "**" {
+			fullFlush = true
+		}
+	}
+
+	if fullFlush {
+		s.Cache.Reset()
+	} else {
+		for _, pattern := range req.Patterns {
+			nodes, err := s.MetricIndex.Find(req.OrgId, pattern, 0)
+			if err != nil {
+				res.Errors += 1
+				code = 500
+			} else {
+				for _, node := range nodes {
+					for _, def := range node.Defs {
+						delResult := s.Cache.DelMetric(def.Id)
+						res.DeletedSeries += delResult.Series
+						res.DeletedArchives += delResult.Archives
+					}
 				}
 			}
 		}

mdata/cache/accnt/flat_accnt.go

@@ -173,6 +173,7 @@ func (a *FlatAccnt) eventLoop() {
 				a.metrics = make(map[string]*FlatAccntMet)
 				a.total = 0
 				a.lru.reset()
+				cacheSizeUsed.SetUint64(a.total)
 			}
 
 			// evict until we're below the max

mdata/cache/cache_mock.go

@@ -57,3 +57,5 @@ func (mc *MockCache) DelMetric(key string) *CCDelMetricResult {
 	mc.DelMetricKeys = append(mc.DelMetricKeys, key)
 	return &mc.DelMetricRes
 }
+
+func (mc *MockCache) Reset() {}

mdata/cache/ccache.go

@@ -153,8 +153,8 @@ func (c *CCache) Add(metric, rawMetric string, cons consolidation.Consolidator,
 }
 
 func (cc *CCache) Reset() {
-	cc.accnt.Reset()
 	cc.Lock()
+	cc.accnt.Reset()
 	cc.metricCache = make(map[string]*CCacheMetric)
 	cc.metricRawKeys = make(map[string]map[consolidation.Consolidator]string)
 	cc.Unlock()

mdata/cache/if.go

@@ -13,6 +13,7 @@ type Cache interface {
 	Stop()
 	Search(context.Context, string, uint32, uint32) *CCSearchResult
 	DelMetric(string) *CCDelMetricResult
+	Reset()
 }
 
 type CachePusher interface {