Method AddAlert

k8s/store.go:60–81

AddAlert adds an alert to the store. Duplicates (same Type+Object) are skipped to prevent alert accumulation from repeated poll cycles detecting the same condition.

(alert Alert)

// AddAlert adds an alert to the store. Duplicates (same Type+Object) are skipped
// to prevent alert accumulation from repeated poll cycles detecting the same condition.
func (s *ObservabilityStore) AddAlert(alert Alert) {
	s.mu.Lock()
	defer s.mu.Unlock()

	// Dedup: skip if same Type+Object already exists in window
	for _, existing := range s.alerts {
		if existing.Type == alert.Type && existing.Object == alert.Object {
			return
		}
	}

	s.alerts = append(s.alerts, alert)
	// Keep only alerts within the window
	cutoff := time.Now().Add(-s.window)
	filtered := s.alerts[:0]
	for _, a := range s.alerts {
		if a.Timestamp.After(cutoff) {
			filtered = append(filtered, a)
		}
	}
	s.alerts = filtered
}

// LatestSnapshot returns the most recent snapshot, if any.
func (s *ObservabilityStore) LatestSnapshot() (ResourceSnapshot, bool) {