diff options
Diffstat (limited to 'designate/manage/pool_manager_cache.py')
-rw-r--r-- | designate/manage/pool_manager_cache.py | 66 |
1 files changed, 0 insertions, 66 deletions
diff --git a/designate/manage/pool_manager_cache.py b/designate/manage/pool_manager_cache.py deleted file mode 100644 index c0c997e8..00000000 --- a/designate/manage/pool_manager_cache.py +++ /dev/null @@ -1,66 +0,0 @@ -# Copyright 2012 Managed I.T. -# -# Author: Kiall Mac Innes <kiall@managedit.ie> -# -# Licensed under the Apache License, Version 2.0 (the "License"); you may -# not use this file except in compliance with the License. You may obtain -# a copy of the License at -# -# http://www.apache.org/licenses/LICENSE-2.0 -# -# Unless required by applicable law or agreed to in writing, software -# distributed under the License is distributed on an "AS IS" BASIS, WITHOUT -# WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. See the -# License for the specific language governing permissions and limitations -# under the License. -import os - - -from migrate.versioning import api as versioning_api -from oslo_config import cfg -from oslo_db import exception - -from designate.manage import base -from designate.sqlalchemy import utils - - -REPOSITORY = os.path.abspath(os.path.join(os.path.dirname(__file__), '..', - 'pool_manager', - 'cache', 'impl_sqlalchemy', - 'migrate_repo')) -cfg.CONF.import_opt('connection', - 'designate.pool_manager.cache.impl_sqlalchemy', - group='pool_manager_cache:sqlalchemy') - -cfg.CONF.import_opt('connection', - 'designate.storage.impl_sqlalchemy', - group='storage:sqlalchemy') - -CONF = cfg.CONF - - -def get_manager(): - storage_db = CONF['storage:sqlalchemy'].connection - pool_manager_cache_db = CONF['pool_manager_cache:sqlalchemy'].connection - if storage_db == pool_manager_cache_db: - raise exception.DBMigrationError( - message=( - "Pool Manager Cache requires its own database." - " Please check your config file." - )) - else: - return utils.get_migration_manager(REPOSITORY, pool_manager_cache_db) - - -class DatabaseCommands(base.Commands): - def version(self): - current = get_manager().version() - latest = versioning_api.version(repository=REPOSITORY).value - print("Current: %s Latest: %s" % (current, latest)) - - def sync(self): - get_manager().upgrade(None) - - @base.args('revision', nargs='?') - def upgrade(self, revision): - get_manager().upgrade(revision) |