Add more integration tests

Signed-off-by: Ruben Vargas <ruben.vp8510@gmail.com>

integration/e2e/api_test.go

@@ -149,14 +149,44 @@ func TestSearchTagValuesV2(t *testing.T) {
 
 	for _, tc := range testCases {
 		t.Run(tc.name, func(t *testing.T) {
-			callSearchTagValuesAndAssert(t, tempo, tc.tagName, tc.query, tc.expected)
+			callSearchTagValuesAndAssert(t, tempo, tc.tagName, tc.query, tc.expected, 0, 0)
 		})
 	}
+
+	// Wait to block flushed to backend
+	time.Sleep(5)
+
+	// Assert no more on the ingester
+	for _, tc := range testCases {
+		t.Run(tc.name, func(t *testing.T) {
+			callSearchTagValuesAndAssert(t, tempo, tc.tagName, tc.query, searchTagValuesResponse{}, 0, 0)
+		})
+	}
+
+	// Assert tags on storage backend
+	now := time.Now()
+	startOfDay := time.Date(now.Year(), now.Month(), now.Day(), 0, 0, 0, 0, now.Location())
+	endOfDay := time.Date(now.Year(), now.Month(), now.Day(), 23, 59, 59, 999999999, now.Location())
+
+	for _, tc := range testCases {
+		t.Run(tc.name, func(t *testing.T) {
+			callSearchTagValuesAndAssert(t, tempo, tc.tagName, tc.query, searchTagValuesResponse{}, startOfDay.Unix(), endOfDay.Unix())
+		})
+	}
+
 }
 
-func callSearchTagValuesAndAssert(t *testing.T, svc *e2e.HTTPService, tagName, query string, expected searchTagValuesResponse) {
+func callSearchTagValuesAndAssert(t *testing.T, svc *e2e.HTTPService, tagName, query string, expected searchTagValuesResponse, start, end int64) {
 	urlPath := fmt.Sprintf(`/api/v2/search/tag/%s/values?q=%s`, tagName, url.QueryEscape(query))
 
+	if start != 0 {
+		urlPath = fmt.Sprintf("%s&start=0", urlPath)
+	}
+
+	if end != 0 {
+		urlPath = fmt.Sprintf("%s&end=0", urlPath)
+	}
+
 	// search for tag values
 	req, err := http.NewRequest(http.MethodGet, "http://"+svc.Endpoint(3200)+urlPath, nil)
 	require.NoError(t, err)