Function TestOverridesAPIWithS3Error

integration/overrides_test.go:290–373

(t *testing.T)

}

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

	minio := e2edb.NewMinio(9001, "cortex")
	require.NoError(t, s.StartAndWaitReady(minio))

	runtimeConfig := map[string]interface{}{
		"overrides": map[string]interface{}{
			"user1": map[string]interface{}{
				"ingestion_rate": 5000,
			},
		},
		"api_allowed_limits": []string{
			"ingestion_rate",
			"max_global_series_per_user",
			"max_global_series_per_metric",
			"ingestion_burst_size",
			"ruler_max_rules_per_rule_group",
			"ruler_max_rule_groups_per_tenant",
		},
	}
	uploadRuntimeConfig(t, minio, runtimeConfig)

	cortexSvc := e2ecortex.NewSingleBinary("cortex-overrides-s3-error", defaultArgsOverrides(minio), "")
	require.NoError(t, s.StartAndWaitReady(cortexSvc))

	// Delete runtime.yaml from S3 to simulate file being missing
	s3Client, err := s3.NewBucketWithConfig(nil, s3.Config{
		Endpoint:  minio.HTTPEndpoint(),
		Insecure:  true,
		Bucket:    "cortex",
		AccessKey: e2edb.MinioAccessKey,
		SecretKey: e2edb.MinioSecretKey,
	}, "overrides-test-delete", nil)
	require.NoError(t, err)
	require.NoError(t, s3Client.Delete(context.Background(), "runtime.yaml"))

	t.Run("GET overrides when runtime.yaml is missing", func(t *testing.T) {
		req, err := http.NewRequest("GET", "http://"+cortexSvc.HTTPEndpoint()+"/api/v1/user-overrides", nil)
		require.NoError(t, err)
		req.Header.Set("X-Scope-OrgID", "user1")

		resp, err := http.DefaultClient.Do(req)
		require.NoError(t, err)
		defer resp.Body.Close()

		assert.Equal(t, http.StatusInternalServerError, resp.StatusCode)
	})

	t.Run("POST overrides when runtime.yaml is missing", func(t *testing.T) {
		newOverrides := map[string]interface{}{
			"ingestion_rate": 6000,
		}
		requestBody, err := json.Marshal(newOverrides)
		require.NoError(t, err)