support pausing check

apis/monitoring/v1alpha1/cluster_alert.go

@@ -65,6 +65,10 @@ type ClusterAlertSpec struct {
 
 	// Vars contains Icinga Service variables to be used in CheckCommand
 	Vars map[string]string `json:"vars,omitempty"`
+
+	// Indicates that Check is paused
+	// Icinga Services are removed
+	Paused bool `json:"paused,omitempty"`
 }
 
 var _ Alert = &ClusterAlert{}

apis/monitoring/v1alpha1/node_alert.go

@@ -69,6 +69,10 @@ type NodeAlertSpec struct {
 
 	// Vars contains Icinga Service variables to be used in CheckCommand
 	Vars map[string]string `json:"vars,omitempty"`
+
+	// Indicates that Check is paused
+	// Icinga Services are removed
+	Paused bool `json:"paused,omitempty"`
 }
 
 var _ Alert = &NodeAlert{}

apis/monitoring/v1alpha1/pod_alert.go

@@ -69,6 +69,10 @@ type PodAlertSpec struct {
 
 	// Vars contains Icinga Service variables to be used in CheckCommand
 	Vars map[string]string `json:"vars,omitempty"`
+
+	// Indicates that Check is paused
+	// Icinga Services are removed
+	Paused bool `json:"paused,omitempty"`
 }
 
 var _ Alert = &PodAlert{}

pkg/icinga/cluster.go

@@ -37,6 +37,15 @@ func (h *ClusterHost) Apply(alert *api.ClusterAlert) error {
 		return err
 	}
 
+	if alertSpec.Paused {
+		if has {
+			if err := h.DeleteIcingaService(alert.Name, kh); err != nil {
+				return err
+			}
+		}
+		return nil
+	}
+
 	attrs := make(map[string]interface{})
 	if alertSpec.CheckInterval.Seconds() > 0 {
 		attrs["check_interval"] = alertSpec.CheckInterval.Seconds()

pkg/icinga/node.go

@@ -82,6 +82,15 @@ func (h *NodeHost) Apply(alert *api.NodeAlert, node *core.Node) error {
 		return err
 	}
 
+	if alertSpec.Paused {
+		if has {
+			if err := h.DeleteIcingaService(alert.Name, kh); err != nil {
+				return err
+			}
+		}
+		return nil
+	}
+
 	attrs := make(map[string]interface{})
 	if alertSpec.CheckInterval.Seconds() > 0 {
 		attrs["check_interval"] = alertSpec.CheckInterval.Seconds()

pkg/icinga/pod.go

@@ -73,6 +73,15 @@ func (h *PodHost) Apply(alert *api.PodAlert, pod *core.Pod) error {
 		return err
 	}
 
+	if alertSpec.Paused {
+		if has {
+			if err := h.DeleteIcingaService(alert.Name, kh); err != nil {
+				return err
+			}
+		}
+		return nil
+	}
+
 	attrs := make(map[string]interface{})
 	if alertSpec.CheckInterval.Seconds() > 0 {
 		attrs["check_interval"] = alertSpec.CheckInterval.Seconds()