Function TestConfigValidationImportPartitions

rest/config_test.go:247–311

(t *testing.T)

}

func TestConfigValidationImportPartitions(t *testing.T) {

	if !base.IsEnterpriseEdition() {
		t.Skip("Import partitions config validation is enterprise edition only")
	}

	tests := []struct {
		name   string
		config string
		err    string
	}{
		{
			name:   "Import enabled, shared bucket disabled",
			config: `{"databases": {"db": {"import_docs":true, "enable_shared_bucket_access":false}}}`,
			err:    "Invalid configuration - import_docs enabled, but enable_shared_bucket_access not enabled",
		},
		{
			name:   "Import partitions set, shared bucket disabled",
			config: `{"databases": {"db": {"import_partitions":32, "enable_shared_bucket_access":false}}}`,
			err:    "Invalid configuration - import_partitions set, but enable_shared_bucket_access not enabled",
		},
		{
			name:   "Import disabled, but partitions set",
			config: `{"databases": {"db": {"enable_shared_bucket_access":true,"import_docs":false,"import_partitions":32}}}`,
			err:    "Invalid configuration - import_partitions set, but import_docs disabled",
		},
		{
			name:   "Too many partitions",
			config: `{"databases": {"db": {"enable_shared_bucket_access":true,"import_partitions":2048}}}`,
			err:    "valid range for import_partitions is: 1-1024",
		},
		{
			name:   "Not enough partitions",
			config: `{"databases": {"db": {"enable_shared_bucket_access":true,"import_partitions":0}}}`,
			err:    "valid range for import_partitions is: 1-1024",
		},
		{
			name:   "Valid partitions",
			config: `{"databases": {"db": {"enable_shared_bucket_access":true,"import_partitions":32}}}`,
		},
		{
			name:   "Valid partitions, enable_shared_bucket_access default value (true)",
			config: `{"databases": {"db": {"import_partitions":32}}}`,
		},
	}

	for _, test := range tests {
		t.Run(test.name, func(t *testing.T) {
			ctx := base.TestCtx(t)
			buf := bytes.NewBufferString(test.config)
			config, err := readLegacyServerConfig(ctx, buf)
			assert.NoError(t, err)
			errorMessages := config.setupAndValidateDatabases(ctx)
			if test.err != "" {
				require.NotNil(t, errorMessages)
				multiError, ok := errorMessages.(*base.MultiError)
				require.True(t, ok)
				require.Equal(t, multiError.Len(), 1)