Function TestRulesAPIWithNoRules

integration/ruler_test.go:920–978

(t *testing.T)

}

func TestRulesAPIWithNoRules(t *testing.T) {
	s, err := e2e.NewScenario(networkName)
	require.NoError(t, err)
	defer s.Close()

	// Start dependencies.
	consul := e2edb.NewConsul()
	minio := e2edb.NewMinio(9000, rulestoreBucketName)
	require.NoError(t, s.StartAndWaitReady(consul, minio))

	// Configure the ruler.
	overrides := map[string]string{
		// Since we're not going to run any rule, we don't need the
		// store-gateway to be configured to a valid address.
		"-querier.store-gateway-addresses": "localhost:12345",
		// Enable the bucket index so we can skip the initial bucket scan.
		"-blocks-storage.bucket-store.bucket-index.enabled": "true",
		"-ruler.poll-interval":                              "5s",
	}

	rulerFlags := mergeFlags(
		BlocksStorageFlags(),
		RulerFlags(),
		RulerShardingFlags(consul.NetworkHTTPEndpoint()),
		overrides,
	)

	// Start rulers.
	ruler1 := e2ecortex.NewRuler("ruler-1", consul.NetworkHTTPEndpoint(), rulerFlags, "")
	ruler2 := e2ecortex.NewRuler("ruler-2", consul.NetworkHTTPEndpoint(), rulerFlags, "")
	ruler3 := e2ecortex.NewRuler("ruler-3", consul.NetworkHTTPEndpoint(), rulerFlags, "")
	require.NoError(t, s.StartAndWaitReady(ruler1, ruler2, ruler3))

	time.Sleep(5 * time.Second)
	c, err := e2ecortex.NewClient("", "", "", ruler1.HTTPEndpoint(), "user-1")
	require.NoError(t, err)

	testCases := map[string]struct {
		filter e2ecortex.RuleFilter
	}{
		"List Rule Groups With Filter": {
			filter: e2ecortex.RuleFilter{
				MaxRuleGroup: 20,
			},
		},
		"List All Rule Groups With No Filter": {
			filter: e2ecortex.RuleFilter{},
		},
	}

	for name, tc := range testCases {
		t.Run(name, func(t *testing.T) {
			actualGroups, token, err := c.GetPrometheusRules(tc.filter)
			require.NoError(t, err)
			assert.Empty(t, actualGroups)
			assert.Empty(t, token)
		})
	}