Function topMethod

inspector/compute.go:152–204

(cycle int, trigger *types.Trigger)

}

func topMethod(cycle int, trigger *types.Trigger) (*types.TriggerResultSet, error) {
	if trigger.Number == 0 {
		err := errors.New("number can not be 0")
		return nil, err
	}
	trigger_result_set := &types.TriggerResultSet{TriggerResults: make([]*types.TriggerResult, 0), Triggered: false}

	results, err := tsdbClient.Query(fmt.Sprintf("%d", cycle), "", trigger.Tags, "sum", trigger.Metric, true)
	if err != nil {
		return nil, err
	}
	for _, result := range results {
		if len(result.Dps) == 0 {
			continue
		}
		values := make([]float64, 0)
		for _, value := range result.Dps {
			values = append(values, value)
		}
		sort.Sort(sort.Reverse(sort.Float64Slice(values)))
		trigger_result := true
		var count int
		var sum float64
		var current_threshold float64
		for _, value := range values {
			if count >= trigger.Number {
				break
			}
			count += 1
			sum += value
			parameters := make(map[string]interface{}, 8)
			parameters["current_threshold"] = value
			parameters["threshold"] = trigger.Threshold
			expression := fmt.Sprintf("current_threshold %s threshold", trigger.Symbol)
			one_result, err := compute(parameters, expression)
			if err != nil {
				return trigger_result_set, err
			}
			current_threshold = value
			if !one_result {
				trigger_result = false
				break
			}
		}
		if !trigger_result_set.Triggered && trigger_result {
			trigger_result_set.Triggered = trigger_result
			current_threshold = sum / float64(count)
		}
		trigger_result_set.TriggerResults = append(trigger_result_set.TriggerResults, types.NewTriggerResult(trigger.Index, result.Tags, result.AggregateTags, current_threshold, trigger_result))
	}

	return trigger_result_set, nil
}

func bottomMethod(cycle int, trigger *types.Trigger) (*types.TriggerResultSet, error) {
	if trigger.Number == 0 {