Skip to content

Commit ad9a622

Browse files
committed
ingest: respect maxActiveAlerts even for addedJustNow alerts
1 parent c145cd6 commit ad9a622

File tree

1 file changed

+6
-4
lines changed

1 file changed

+6
-4
lines changed

cmd/alertmanager/ingest.go

+6-4
Original file line numberDiff line numberDiff line change
@@ -95,13 +95,15 @@ func deduplicateAndRatelimit(
9595
state *amstate.Store,
9696
maxActiveAlerts int,
9797
) []amstate.Alert {
98-
processed := []amstate.Alert{}
98+
filtered := []amstate.Alert{}
9999

100100
activeAlerts := state.ActiveAlerts()
101101

102+
addedJustNow := func() int { return len(filtered) }
103+
102104
for _, alert := range alerts {
103105
// no more "room"?
104-
if len(activeAlerts) >= maxActiveAlerts {
106+
if (len(activeAlerts) + addedJustNow()) >= maxActiveAlerts {
105107
continue
106108
}
107109

@@ -110,10 +112,10 @@ func deduplicateAndRatelimit(
110112
continue
111113
}
112114

113-
processed = append(processed, alert)
115+
filtered = append(filtered, alert)
114116
}
115117

116-
return processed
118+
return filtered
117119
}
118120

119121
func getMaxFiringAlerts() (int, error) {

0 commit comments

Comments
 (0)