Function doAlarmAction

controller/notify.go:94–108

发送报警

(strategy_event *types.StrategyEvent, trigger_events map[string]*types.TriggerEvent)

//发送报警
func doAlarmAction(strategy_event *types.StrategyEvent, trigger_events map[string]*types.TriggerEvent) {
	strategy_event.Status = types.EVENT_NEW
	actions := mydb.GetAllActions(strategy_event.StrategyID)
	for _, action := range actionFilter(actions, strategy_event) {
		lg.Info("do action:%v", action)
		switch action.Kind {
		case types.ACTION_NOTIFY:
			subject := action.AlarmSubject
			content := fillTemplate(action.AlarmTemplate, generateTemplateObj(strategy_event, triggerEventFilter(trigger_events, types.ACTION_ALARM)))
			go broadcast(strategy_event, subject, content, action)
		case types.ACTION_RUN:
			go doRun(strategy_event, action)
		}
	}
}

//发送恢复通知
func doRestoreAction(strategy_event *types.StrategyEvent, trigger_events map[string]*types.TriggerEvent) {