Function testMetadataQueryParams

integration/ingester_metadata_test.go:156–205

(t *testing.T, client *e2ecortex.Client, metadataMetricNum, metadataPerMetrics int)

}

func testMetadataQueryParams(t *testing.T, client *e2ecortex.Client, metadataMetricNum, metadataPerMetrics int) {
	t.Run("test no parameter", func(t *testing.T) {
		result, err := client.Metadata("", "")
		require.NoError(t, err)
		require.Equal(t, metadataMetricNum, len(result))

		for _, v := range result {
			require.Equal(t, metadataPerMetrics, len(v))
		}
	})

	t.Run("test name parameter", func(t *testing.T) {
		t.Run("existing name", func(t *testing.T) {
			name := "metadata_name_0"
			result, err := client.Metadata(name, "")
			require.NoError(t, err)
			m, ok := result[name]
			require.True(t, ok)
			require.Equal(t, metadataPerMetrics, len(m))
		})
		t.Run("existing name with limit 0", func(t *testing.T) {
			name := "metadata_name_0"
			result, err := client.Metadata(name, "0")
			require.NoError(t, err)
			require.Equal(t, 0, len(result))
		})
		t.Run("non-existing name", func(t *testing.T) {
			result, err := client.Metadata("dummy", "")
			require.NoError(t, err)
			require.Equal(t, 0, len(result))
		})
	})

	t.Run("test limit parameter", func(t *testing.T) {
		t.Run("less than length of metadata", func(t *testing.T) {
			result, err := client.Metadata("", "3")
			require.NoError(t, err)
			require.Equal(t, 3, len(result))
		})
		t.Run("limit: 0", func(t *testing.T) {
			result, err := client.Metadata("", "0")
			require.NoError(t, err)
			require.Equal(t, 0, len(result))
		})
		t.Run("invalid limit", func(t *testing.T) {
			_, err := client.Metadata("", "dummy")
			require.Error(t, err)
		})
	})
}