Fix trendValue/consolidateBy

pkg/datasource/functions.go

@@ -53,7 +53,7 @@ var filterFuncMap map[string]AggDataProcessingFunc
 
 var timeFuncMap map[string]PreProcessingFunc
 
-var frontendFuncMap map[string]bool
+var skippedFuncMap map[string]bool
 
 func init() {
 	seriesFuncMap = map[string]DataProcessingFunc{
@@ -87,11 +87,13 @@ func init() {
 		"timeShift": applyTimeShiftPre,
 	}
 
-	// Functions processing on the frontend
+	// Functions not processing here or processing on the frontend, skip it
-	frontendFuncMap = map[string]bool{
+	skippedFuncMap = map[string]bool{
 		"setAlias":        true,
 		"replaceAlias":    true,
 		"setAliasByRegex": true,
+		"trendValue":      true,
+		"consolidateBy":   true,
 	}
 }
 
@@ -117,7 +119,7 @@ func applyFunctions(series []*timeseries.TimeSeriesData, functions []QueryFuncti
 				return nil, err
 			}
 			series = result
-		} else if _, ok := frontendFuncMap[f.Def.Name]; ok {
+		} else if _, ok := skippedFuncMap[f.Def.Name]; ok {
 			continue
 		} else {
 			err := errFunctionNotSupported(f.Def.Name)

pkg/datasource/zabbix.go

@@ -73,7 +73,7 @@ func (ds *ZabbixDatasourceInstance) queryNumericDataForItems(ctx context.Context
 		return nil, err
 	}
 
-	history, err := ds.getHistotyOrTrend(ctx, query, items, valueType)
+	history, err := ds.getHistotyOrTrend(ctx, query, items, consolidateBy)
 	if err != nil {
 		return nil, err
 	}
@@ -101,7 +101,7 @@ func (ds *ZabbixDatasourceInstance) getTrendValueType(query *QueryModel) string
 }
 
 func (ds *ZabbixDatasourceInstance) getConsolidateBy(query *QueryModel) string {
-	consolidateBy := "avg"
+	consolidateBy := ""
 
 	for _, fn := range query.Functions {
 		if fn.Def.Name == "consolidateBy" && len(fn.Params) > 0 {