cluster test for getKeyInfo for hll

Author: oliver006

exporter/exporter_test.go

@@ -33,7 +33,6 @@ var (
 	keysExpiring    []string
 	listKeys        []string
 	singleStringKey string
-	ts              = int32(time.Now().Unix())
 
 	dbNumStr        = "11"
 	altDBNumStr     = "12"
@@ -457,15 +456,17 @@ func init() {
 		log.SetLevel(log.InfoLevel)
 	}
 
+	testTimestamp := time.Now().Unix()
+
 	for _, n := range []string{"john", "paul", "ringo", "george"} {
-		keys = append(keys, fmt.Sprintf("key_%s_%d", n, ts))
+		keys = append(keys, fmt.Sprintf("key_%s_%d", n, testTimestamp))
 	}
 
-	singleStringKey = fmt.Sprintf("key_string_%d", ts)
+	singleStringKey = fmt.Sprintf("key_string_%d", testTimestamp)
 
 	listKeys = append(listKeys, "beatles_list")
 
 	for _, n := range []string{"A.J.", "Howie", "Nick", "Kevin", "Brian"} {
-		keysExpiring = append(keysExpiring, fmt.Sprintf("key_exp_%s_%d", n, ts))
+		keysExpiring = append(keysExpiring, fmt.Sprintf("key_exp_%s_%d", n, testTimestamp))
 	}
 }

exporter/keys_test.go

@@ -102,6 +102,8 @@ func TestClusterKeyValuesAndSizes(t *testing.T) {
 				CheckSingleKeys: dbNumStrFull + "=" + url.QueryEscape(keys[0]),
 				IsCluster:       true},
 		)
+		ts := httptest.NewServer(e)
+		defer ts.Close()
 
 		uri := os.Getenv("TEST_REDIS_CLUSTER_MASTER_URI")
 
@@ -134,6 +136,11 @@ func TestClusterKeyValuesAndSizes(t *testing.T) {
 				t.Errorf("didn't find %s", k)
 			}
 		}
+
+		body := downloadURL(t, ts.URL+"/metrics")
+		if !strings.Contains(body, `redis_key_value{db="db0",key="`+TestHllName+`"} 3`) {
+			t.Errorf("Expected metric `redis_key_value` with value 2 but got:\n%s", body)
+		}
 	}
 }