feedback

pkg/ingester-rf1/ingester.go

@@ -410,7 +410,7 @@ func (i *Ingester) starting(ctx context.Context) error {
 	// start our loop
 	i.loopDone.Add(1)
 	go i.loop()
-	go i.cleanerLoop()
+	go i.periodicStreamMaintenance()
 	return nil
 }
 
@@ -509,11 +509,10 @@ func (i *Ingester) loop() {
 	}
 }
 
-func (i *Ingester) cleanerLoop() {
-	// No need to signal loopDone wg in this loop, as cleaning is non-essential.
+func (i *Ingester) periodicStreamMaintenance() {
+	// No need to signal loopDone wg in this loop, as the maintenance loop is non-essential.
 
-	jit := i.cfg.StreamRetainPeriod / 5
-	streamRetentionTicker := util.NewTickerWithJitter(i.cfg.StreamRetainPeriod, jit)
+	streamRetentionTicker := time.NewTicker(i.cfg.StreamRetainPeriod)
 	defer streamRetentionTicker.Stop()
 
 	for {