Check expiry in alert

cluster.go

@@ -399,7 +399,11 @@ func (c *Cluster) Alerts() map[string]api.Alert {
 	c.alertsMux.Lock()
 	defer c.alertsMux.Unlock()
 	for i, alert := range c.alerts {
-		alerts[i] = alert
+		if time.Now().Before(time.Unix(0, alert.Expiry)) {
+			alerts[i] = alert
+		} else {
+			delete(c.alerts, i)
+		}
 	}
 
 	return alerts

monitor/metrics/checker.go

@@ -132,6 +132,7 @@ func (mc *Checker) alert(pid peer.ID, metricName string) error {
 	alrt := &api.Alert{
 		Peer:       pid,
 		MetricName: metricName,
+		Expiry:     time.Now().Add(30 * time.Second).UnixNano(),
 	}
 	select {
 	case mc.alertCh <- alrt: