From 428c78603848c9b53762eb484d51b2972e2fc869 Mon Sep 17 00:00:00 2001 From: Marc Falzon Date: Mon, 28 Jul 2014 22:57:55 +0200 Subject: [PATCH] Add series averaging support to influxdb connector --- pkg/connector/influxdb.go | 9 +++++---- 1 file changed, 5 insertions(+), 4 deletions(-) diff --git a/pkg/connector/influxdb.go b/pkg/connector/influxdb.go index 3710ee53..dddeb0ad 100644 --- a/pkg/connector/influxdb.go +++ b/pkg/connector/influxdb.go @@ -127,10 +127,11 @@ func (connector *InfluxDBConnector) GetPlots(query *plot.Query) ([]plot.Series, } return []plot.Series{sumSeries}, nil } else if query.Group.Type == OperGroupTypeAvg { - return nil, fmt.Errorf( - "influxdb[%s]: average series grouping not supported by influxdb connector", - connector.name, - ) + avgSeries, err := plot.AvgSeries(resultSeries) + if err != nil { + return nil, fmt.Errorf("influxdb[%s]: unable to average series: %s", connector.name, err) + } + return []plot.Series{avgSeries}, nil } else { return resultSeries, nil }