diff --git a/cmd/influxd/server_integration_test.go b/cmd/influxd/server_integration_test.go index 26b79f0ddfb..9affda10e0e 100644 --- a/cmd/influxd/server_integration_test.go +++ b/cmd/influxd/server_integration_test.go @@ -617,6 +617,44 @@ func runTestsData(t *testing.T, testName string, nodes Cluster, database, retent queryDb: "%DB%", expected: `{"results":[{"series":[{"name":"cpu","columns":["time","mean","stddev"],"values":[["2000-01-01T00:00:00Z",5,2.138089935299395]]}]}]}`, }, + { + reset: true, + name: "first value", + write: `{"database" : "%DB%", "retentionPolicy" : "%RP%", "points": [ + {"name": "cpu", "timestamp": "2000-01-01T00:00:00Z", "fields": {"value": 2}}, + {"name": "cpu", "timestamp": "2000-01-01T00:01:00Z", "fields": {"value": 7}}, + {"name": "cpu", "timestamp": "2000-01-01T00:01:10Z", "fields": {"value": 9}} + ]}`, + query: `SELECT first(value) FROM cpu`, + queryDb: "%DB%", + // FIXME: returned time should be "2000-01-01T00:00:00Z" + expected: `{"results":[{"series":[{"name":"cpu","columns":["time","first"],"values":[["1970-01-01T00:00:00Z",2]]}]}]}`, + }, + { + reset: true, + name: "last value", + write: `{"database" : "%DB%", "retentionPolicy" : "%RP%", "points": [ + {"name": "cpu", "timestamp": "2000-01-01T00:00:00Z", "fields": {"value": 2}}, + {"name": "cpu", "timestamp": "2000-01-01T00:01:00Z", "fields": {"value": 7}}, + {"name": "cpu", "timestamp": "2000-01-01T00:01:10Z", "fields": {"value": 9}} + ]}`, + query: `SELECT last(value) FROM cpu`, + queryDb: "%DB%", + // FIXME: returned time should be "2000-01-01T00:01:10Z" + expected: `{"results":[{"series":[{"name":"cpu","columns":["time","last"],"values":[["1970-01-01T00:00:00Z",9]]}]}]}`, + }, + { + reset: true, + name: "value spread", + write: `{"database" : "%DB%", "retentionPolicy" : "%RP%", "points": [ + {"name": "cpu", "timestamp": "2000-01-01T00:00:00Z", "fields": {"value": 2}}, + {"name": "cpu", "timestamp": "2000-01-01T00:01:00Z", "fields": {"value": 7}}, + {"name": "cpu", "timestamp": "2000-01-01T00:01:10Z", "fields": {"value": 9}} + ]}`, + query: `SELECT spread(value) FROM cpu`, + queryDb: "%DB%", + expected: `{"results":[{"series":[{"name":"cpu","columns":["time","spread"],"values":[["1970-01-01T00:00:00Z",7]]}]}]}`, + }, { reset: true, name: "aggregations",