function: add support for timestamp() (#145)

Signed-off-by: Ziqi Zhao <[email protected]> Signed-off-by: Ziqi Zhao <[email protected]>
thanos-io · Jan 9, 2023 · 3773ec3 · 3773ec3
1 parent a831c7b
commit 3773ec3
Show file tree

Hide file tree

Showing 2 changed files with 15 additions and 0 deletions.
diff --git a/engine/engine_test.go b/engine/engine_test.go
@@ -281,6 +281,13 @@ func TestQueriesAgainstOldEngine(t *testing.T) {
 					http_requests_total{pod="nginx-2"} 1`,
 			query: "atanh(http_requests_total)",
 		},
+		{
+			name: "timestamp",
+			load: `load 30s
+					http_requests_total{pod="nginx-1"} 0
+					http_requests_total{pod="nginx-2"} 1`,
+			query: "timestamp(http_requests_total)",
+		},
 		{
 			name: "rad",
 			load: `load 30s

diff --git a/execution/function/functions.go b/execution/function/functions.go
@@ -72,6 +72,14 @@ var Funcs = map[string]FunctionCall{
 	"deg": simpleFunc(func(v float64) float64 {
 		return v * 180 / math.Pi
 	}),
+	"timestamp": func(f FunctionArgs) promql.Sample {
+		return promql.Sample{
+			Point: promql.Point{
+				T: f.StepTime,
+				V: float64(f.Points[0].T) / 1000,
+			},
+		}
+	},
 	"pi": func(f FunctionArgs) promql.Sample {
 		return promql.Sample{
 			Point: promql.Point{