summaryrefslogtreecommitdiff
path: root/designate/manage/pool_manager_cache.py
diff options
context:
space:
mode:
Diffstat (limited to 'designate/manage/pool_manager_cache.py')
-rw-r--r--designate/manage/pool_manager_cache.py66
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)