delete no use code: repeater.go

src/server/engine/engine.go

@@ -20,9 +20,6 @@ func Start(ctx context.Context) error {
 	// filter my rules and start worker
 	go loopFilterRules(ctx)
 
-	// repeat notifier
-	// go loopRepeat(ctx)
-
 	go reportQueueSize()
 
 	return nil

src/server/engine/repeat.go

@@ -1,86 +0,0 @@
-package engine
-
-import (
-	"context"
-	"time"
-
-	"github.com/toolkits/pkg/logger"
-
-	"github.com/didi/nightingale/v5/src/models"
-	"github.com/didi/nightingale/v5/src/server/config"
-	"github.com/didi/nightingale/v5/src/server/memsto"
-	"github.com/didi/nightingale/v5/src/server/naming"
-)
-
-func loopRepeat(ctx context.Context) {
-	duration := time.Duration(9000) * time.Millisecond
-	for {
-		select {
-		case <-ctx.Done():
-			return
-		case <-time.After(duration):
-			repeat()
-		}
-	}
-}
-
-// 拉取未恢复的告警表中需要重复通知的数据
-func repeat() {
-	isLeader, err := naming.IamLeader()
-	if err != nil {
-		logger.Errorf("repeat: %v", err)
-		return
-	}
-
-	if !isLeader {
-		logger.Info("repeat: i am not leader")
-		return
-	}
-
-	events, err := models.AlertCurEventNeedRepeat(config.C.ClusterName)
-	if err != nil {
-		logger.Errorf("repeat: AlertCurEventNeedRepeat: %v", err)
-		return
-	}
-
-	if len(events) == 0 {
-		return
-	}
-
-	for i := 0; i < len(events); i++ {
-		rule := memsto.AlertRuleCache.Get(events[i].RuleId)
-		if rule == nil {
-			// 可能告警规则已经被删了，理论上不应该出现这种情况，因为删除告警规则的时候，会顺带删除活跃告警，无论如何，自保一下
-			continue
-		}
-
-		repeatOne(events[i], rule)
-
-		if err = events[i].IncRepeatStep(int64(rule.NotifyRepeatStep * 60)); err != nil {
-			logger.Errorf("repeat: IncRepeatStep: %v", err)
-		}
-	}
-}
-
-func repeatOne(event *models.AlertCurEvent, rule *models.AlertRule) {
-	if rule.NotifyRepeatStep == 0 {
-		// 用户后来调整了这个字段，不让继续发送了
-		return
-	}
-
-	event.DB2Mem()
-
-	// 重复通知的告警，应该用新的时间来判断是否生效和是否屏蔽，
-	// 不能使用TriggerTime，因为TriggerTime是触发时的时间，是一个比较老的时间
-	// 先发了告警，又做了屏蔽，本质是不想发了，如果继续用TriggerTime判断，就还是会发，不符合预期
-	if isNoneffective(event.NotifyRepeatNext, rule) {
-		return
-	}
-
-	if isMuted(event, event.NotifyRepeatNext) {
-		return
-	}
-
-	fillUsers(event)
-	notify(event)
-}