From 3f5beb7c9fdd30aabd291892f76fc978fea9290b Mon Sep 17 00:00:00 2001 From: liugq Date: Thu, 27 Jul 2023 15:15:15 +0800 Subject: [PATCH] add enabled field to channel --- model/alerting/destination.go | 1 + service/alerting/elasticsearch/engine.go | 3 +++ 2 files changed, 4 insertions(+) diff --git a/model/alerting/destination.go b/model/alerting/destination.go index dee045ce..7b4a9f74 100644 --- a/model/alerting/destination.go +++ b/model/alerting/destination.go @@ -17,6 +17,7 @@ type Channel struct { SearchText string `json:"-" elastic_mapping:"search_text:{type:text,index_prefixes:{},index_phrases:true, analyzer:suggest_text_search }"` SubType string `json:"sub_type" elastic_mapping:"sub_type:{type:keyword,copy_to:search_text}"` Email *Email `json:"email,omitempty" elastic_mapping:"email:{type:object}"` + Enabled bool `json:"enabled" elastic_mapping:"enabled:{type:boolean}"` } diff --git a/service/alerting/elasticsearch/engine.go b/service/alerting/elasticsearch/engine.go index 13585831..0bf1b0b4 100644 --- a/service/alerting/elasticsearch/engine.go +++ b/service/alerting/elasticsearch/engine.go @@ -959,6 +959,9 @@ func performChannels(channels []alerting.Channel, ctx map[string]interface{}) ([ var errCount int var actionResults []alerting.ActionExecutionResult for _, channel := range channels { + if !channel.Enabled { + continue + } resBytes, err, messageBytes := common.PerformChannel(&channel, ctx) var errStr string if err != nil {