Function triggerEventFilter

controller/notify.go:127–144

(trigger_events map[string]*types.TriggerEvent, action_type int)

}

func triggerEventFilter(trigger_events map[string]*types.TriggerEvent, action_type int) map[string]*types.TriggerEvent {
	new_trigger_events := make(map[string]*types.TriggerEvent)
	switch action_type {
	case types.ACTION_ALARM:
		for index, trigger_event := range trigger_events {
			if trigger_event.Triggered == true {
				new_trigger_events[index] = trigger_event
			}
		}
	case types.ACTION_RESTORE:
		for index, trigger_event := range trigger_events {
			if trigger_event.TriggerChanged == true {
				new_trigger_events[index] = trigger_event
			}
		}
	}
	return new_trigger_events
}

func actionFilter(actions []*types.Action, strategy_event *types.StrategyEvent) []*types.Action {
	filtered := make([]*types.Action, 0)