Method processTask

inspector/inspector.go:167–227

(task *types.AlarmTask)

}

func (this *Inspector) processTask(task *types.AlarmTask) {
	triggers_results := make(map[string]*types.TriggerResultSet)
	parameters := make(map[string]interface{})
	host_id := strings.SplitN(task.ID, "@", 2)[1]
	error_message := ""
	for index, trigger := range task.Triggers {
		var trigger_result_set *types.TriggerResultSet
		var err error
		if trigger.Tags == "" {
			trigger.Tags = fmt.Sprintf("uuid=%s", host_id)
		} else {
			trigger.Tags = fmt.Sprintf("%s,uuid=%s", trigger.Tags, host_id)
		}
		switch trigger.Method {
		case MAX_METHOD:
			trigger_result_set, err = maxMethod(task.Strategy.Cycle, trigger)
		case MIN_METHOD:
			trigger_result_set, err = minMethod(task.Strategy.Cycle, trigger)
		case RATIO_METHOD:
			trigger_result_set, err = ratioMethod(task.Strategy.Cycle, trigger)
		case TOP_METHOD:
			trigger_result_set, err = topMethod(task.Strategy.Cycle, trigger)
		case BOTTOM_METHOD:
			trigger_result_set, err = bottomMethod(task.Strategy.Cycle, trigger)
		case LAST_METHOD:
			trigger_result_set, err = lastMethod(task.Strategy.Cycle, trigger)
		case DIFF_METHOD:
			trigger_result_set, err = diffMethod(task.Strategy.Cycle, trigger)
		case NODATA_METHOD:
			trigger_result_set, err = nodataMethod(task.Strategy.Cycle, trigger)
		case AVG_METHOD:
			trigger_result_set, err = avgMethod(task.Strategy.Cycle, trigger)
		default:
			err = errors.New(fmt.Sprintf("trigger method %v not found", trigger.Method))
		}

		if err != nil {
			error_message = err.Error()
			break
		}

		if len(trigger_result_set.TriggerResults) == 0 {
			error_message = "no data"
			break
		}
		triggers_results[index] = trigger_result_set
		parameters[index] = trigger_result_set.Triggered
	}

	result := false
	if error_message == "" {
		compute_result, err := compute(parameters, task.Strategy.Expression)
		if err != nil {
			error_message = err.Error()
		}
		result = compute_result
	}