|
1 |
| -//go:build requires_docker |
2 |
| -// +build requires_docker |
3 |
| - |
4 | 1 | package integration
|
5 | 2 |
|
6 | 3 | import (
|
@@ -96,7 +93,27 @@ func TestNativeHistogramIngestionAndQuery(t *testing.T) {
|
96 | 93 | c, err = e2ecortex.NewClient("", queryFrontend.HTTPEndpoint(), "", "", "user-1")
|
97 | 94 | require.NoError(t, err)
|
98 | 95 |
|
99 |
| - result, err := c.Query(`series_1`, series2Timestamp) |
| 96 | + result, err := c.QueryRange(`series_1`, series2Timestamp.Add(-time.Minute*10), series2Timestamp, time.Second) |
| 97 | + require.NoError(t, err) |
| 98 | + require.Equal(t, model.ValMatrix, result.Type()) |
| 99 | + m := result.(model.Matrix) |
| 100 | + require.Equal(t, 2, m.Len()) |
| 101 | + for _, ss := range m { |
| 102 | + require.Empty(t, ss.Values) |
| 103 | + require.NotEmpty(t, ss.Histograms) |
| 104 | + } |
| 105 | + |
| 106 | + result, err = c.QueryRange(`series_2`, series2Timestamp.Add(-time.Minute*10), series2Timestamp, time.Second) |
| 107 | + require.NoError(t, err) |
| 108 | + require.Equal(t, model.ValMatrix, result.Type()) |
| 109 | + m = result.(model.Matrix) |
| 110 | + require.Equal(t, 2, m.Len()) |
| 111 | + for _, ss := range m { |
| 112 | + require.Empty(t, ss.Values) |
| 113 | + require.NotEmpty(t, ss.Histograms) |
| 114 | + } |
| 115 | + |
| 116 | + result, err = c.Query(`series_1`, series2Timestamp) |
100 | 117 | require.NoError(t, err)
|
101 | 118 | require.Equal(t, model.ValVector, result.Type())
|
102 | 119 | v := result.(model.Vector)
|
|
0 commit comments