FFM-11660 Add a stop clearing method

Author: erdirowlands

analyticsservice/analytics.go

@@ -51,6 +51,7 @@ type SafeSeenTargetsCache[K comparable, V any] interface {
 	SafeAnalyticsCache[K, V]
 	setWithLimit(key K, value V)
 	isLimitExceeded() bool
+	stopClearing()
 }
 
 type analyticsEvent struct {
@@ -110,6 +111,8 @@ func (as *AnalyticsService) startTimer(ctx context.Context) {
 			timeStamp := time.Now().UnixNano() / (int64(time.Millisecond) / int64(time.Nanosecond))
 			as.sendDataAndResetCache(ctx, timeStamp)
 		case <-ctx.Done():
+			close(as.analyticsChan)
+			as.seenTargets.stopClearing()
 			as.logger.Infof("%s Metrics stopped", sdk_codes.MetricsStopped)
 			return
 		}

analyticsservice/safe_seen_targets_map.go

@@ -90,6 +90,16 @@ func (s *safeSeenTargets) iterate(f func(string, bool)) {
 	}
 }
 
+func (s *safeSeenTargets) stopClearing() {
+	s.Lock()
+	defer s.Unlock()
+
+	if s.clearingTimer != nil {
+		s.clearingTimer.Stop()
+		s.clearingTimer = nil
+	}
+}
+
 func (s *safeSeenTargets) isLimitExceeded() bool {
 	return s.limitExceeded.Load()
 }