Function TestReadMetrics

integration/operations/operational_metrics_test.go:71–186

(t *testing.T)

}

func TestReadMetrics(t *testing.T) {
	util.RunIntegrationTests(t, util.TestHarnessConfig{}, func(h *util.TempoHarness) {
		h.WaitTracesWritable(t)

		info := tempoUtil.NewTraceInfo(time.Now(), "")
		require.NoError(t, h.WriteTraceInfo(info, ""))

		h.WaitTracesQueryable(t, 1)

		// http
		apiClient := h.APIClientHTTP("")

		_, err := apiClient.MetricsQueryInstant("{} | rate()", time.Now().Add(-time.Hour).Unix(), time.Now().Unix(), 0)
		require.NoError(t, err)
		_, err = apiClient.MetricsQueryRange("{} | rate()", time.Now().Add(-time.Hour).Unix(), time.Now().Unix(), "1m", 0)
		require.NoError(t, err)
		id, err := info.TraceID()
		require.NoError(t, err)
		_, err = apiClient.QueryTraceV2(tempoUtil.TraceIDToHexString(id))
		require.NoError(t, err)
		_, err = apiClient.SearchTagValuesV2("span.foo", "")
		require.NoError(t, err)
		_, err = apiClient.SearchTagsV2()
		require.NoError(t, err)
		_, err = apiClient.SearchTraceQL("{}")
		require.NoError(t, err)

		// grpc
		grpcClient, ctx, err := h.APIClientGRPC("")
		require.NoError(t, err)
		instantClient, err := grpcClient.MetricsQueryInstant(ctx, &tempopb.QueryInstantRequest{
			Query: "{} | rate()",
			Start: uint64(time.Now().Add(-time.Hour).Local().UnixNano()),
			End:   uint64(time.Now().Local().UnixNano()),
		})
		require.NoError(t, err)
		err = drainStreamingClient(instantClient)
		require.NoError(t, err)

		rangeClient, err := grpcClient.MetricsQueryRange(ctx, &tempopb.QueryRangeRequest{
			Query:     "{} | rate()",
			Start:     uint64(time.Now().Add(-time.Hour).Local().UnixNano()),
			End:       uint64(time.Now().Local().UnixNano()),
			Step:      uint64(time.Minute.Nanoseconds()),
			Exemplars: 0,
		})
		require.NoError(t, err)
		err = drainStreamingClient(rangeClient)
		require.NoError(t, err)

		searchTagValuesClient, err := grpcClient.SearchTagValuesV2(ctx, &tempopb.SearchTagValuesRequest{
			TagName: "span.foo",
			Query:   "",
		})
		require.NoError(t, err)
		err = drainStreamingClient(searchTagValuesClient)
		require.NoError(t, err)