Drop postgresql support
Remove postgresql DB support; This feature is untested as part of the charms, is not in use and was deprecated as part of the 1708 charms release. Change-Id: I5ebd4af9da38c03ca9952b8eed02fe5783692445
This commit is contained in:
parent
66b643524e
commit
11bb8503d1
@ -24,7 +24,6 @@ from charmhelpers.core.hookenv import (
|
|||||||
Hooks,
|
Hooks,
|
||||||
UnregisteredHookError,
|
UnregisteredHookError,
|
||||||
config,
|
config,
|
||||||
is_relation_made,
|
|
||||||
local_unit,
|
local_unit,
|
||||||
log,
|
log,
|
||||||
DEBUG,
|
DEBUG,
|
||||||
@ -323,13 +322,6 @@ def amqp_changed():
|
|||||||
|
|
||||||
@hooks.hook('shared-db-relation-joined')
|
@hooks.hook('shared-db-relation-joined')
|
||||||
def db_joined():
|
def db_joined():
|
||||||
if is_relation_made('pgsql-db'):
|
|
||||||
# error, postgresql is used
|
|
||||||
e = ('Attempting to associate a mysql database when there is already '
|
|
||||||
'associated a postgresql one')
|
|
||||||
log(e, level=ERROR)
|
|
||||||
raise Exception(e)
|
|
||||||
|
|
||||||
if config('prefer-ipv6'):
|
if config('prefer-ipv6'):
|
||||||
sync_db_with_multi_ipv6_addresses(config('database'),
|
sync_db_with_multi_ipv6_addresses(config('database'),
|
||||||
config('database-user'))
|
config('database-user'))
|
||||||
@ -348,18 +340,6 @@ def db_joined():
|
|||||||
hostname=host)
|
hostname=host)
|
||||||
|
|
||||||
|
|
||||||
@hooks.hook('pgsql-db-relation-joined')
|
|
||||||
def pgsql_neutron_db_joined():
|
|
||||||
if is_relation_made('shared-db'):
|
|
||||||
# raise error
|
|
||||||
e = ('Attempting to associate a postgresql database'
|
|
||||||
' when there is already associated a mysql one')
|
|
||||||
log(e, level=ERROR)
|
|
||||||
raise Exception(e)
|
|
||||||
|
|
||||||
relation_set(database=config('database'))
|
|
||||||
|
|
||||||
|
|
||||||
@hooks.hook('shared-db-relation-changed')
|
@hooks.hook('shared-db-relation-changed')
|
||||||
@restart_on_change(restart_map())
|
@restart_on_change(restart_map())
|
||||||
def db_changed():
|
def db_changed():
|
||||||
@ -373,20 +353,9 @@ def db_changed():
|
|||||||
neutron_plugin_api_subordinate_relation_joined(relid=r_id)
|
neutron_plugin_api_subordinate_relation_joined(relid=r_id)
|
||||||
|
|
||||||
|
|
||||||
@hooks.hook('pgsql-db-relation-changed')
|
|
||||||
@restart_on_change(restart_map())
|
|
||||||
def postgresql_neutron_db_changed():
|
|
||||||
CONFIGS.write(NEUTRON_CONF)
|
|
||||||
conditional_neutron_migration()
|
|
||||||
|
|
||||||
for r_id in relation_ids('neutron-plugin-api-subordinate'):
|
|
||||||
neutron_plugin_api_subordinate_relation_joined(relid=r_id)
|
|
||||||
|
|
||||||
|
|
||||||
@hooks.hook('amqp-relation-broken',
|
@hooks.hook('amqp-relation-broken',
|
||||||
'identity-service-relation-broken',
|
'identity-service-relation-broken',
|
||||||
'shared-db-relation-broken',
|
'shared-db-relation-broken')
|
||||||
'pgsql-db-relation-broken')
|
|
||||||
def relation_broken():
|
def relation_broken():
|
||||||
CONFIGS.write_all()
|
CONFIGS.write_all()
|
||||||
|
|
||||||
|
@ -182,7 +182,6 @@ BASE_RESOURCE_MAP = OrderedDict([
|
|||||||
user=config('database-user'),
|
user=config('database-user'),
|
||||||
database=config('database'),
|
database=config('database'),
|
||||||
ssl_dir=NEUTRON_CONF_DIR),
|
ssl_dir=NEUTRON_CONF_DIR),
|
||||||
context.PostgresqlDBContext(database=config('database')),
|
|
||||||
neutron_api_context.IdentityServiceContext(
|
neutron_api_context.IdentityServiceContext(
|
||||||
service='neutron',
|
service='neutron',
|
||||||
service_user='neutron'),
|
service_user='neutron'),
|
||||||
@ -222,7 +221,7 @@ BASE_RESOURCE_MAP = OrderedDict([
|
|||||||
# The interface is said to be satisfied if anyone of the interfaces in the
|
# The interface is said to be satisfied if anyone of the interfaces in the
|
||||||
# list has a complete context.
|
# list has a complete context.
|
||||||
REQUIRED_INTERFACES = {
|
REQUIRED_INTERFACES = {
|
||||||
'database': ['shared-db', 'pgsql-db'],
|
'database': ['shared-db'],
|
||||||
'messaging': ['amqp'],
|
'messaging': ['amqp'],
|
||||||
'identity': ['identity-service'],
|
'identity': ['identity-service'],
|
||||||
}
|
}
|
||||||
@ -486,10 +485,6 @@ def resource_map(release=None):
|
|||||||
resource_map[conf]['contexts'].append(
|
resource_map[conf]['contexts'].append(
|
||||||
neutron_api_context.NeutronCCContext())
|
neutron_api_context.NeutronCCContext())
|
||||||
|
|
||||||
# update for postgres
|
|
||||||
resource_map[conf]['contexts'].append(
|
|
||||||
context.PostgresqlDBContext(database=config('database')))
|
|
||||||
|
|
||||||
if ('kilo' <= CompareOpenStackReleases(release) <= 'mitaka' and
|
if ('kilo' <= CompareOpenStackReleases(release) <= 'mitaka' and
|
||||||
config('enable-sriov')):
|
config('enable-sriov')):
|
||||||
resource_map[ML2_SRIOV_INI] = {}
|
resource_map[ML2_SRIOV_INI] = {}
|
||||||
|
@ -1 +0,0 @@
|
|||||||
neutron_api_hooks.py
|
|
@ -1 +0,0 @@
|
|||||||
neutron_api_hooks.py
|
|
@ -1 +0,0 @@
|
|||||||
neutron_api_hooks.py
|
|
@ -34,8 +34,6 @@ provides:
|
|||||||
requires:
|
requires:
|
||||||
shared-db:
|
shared-db:
|
||||||
interface: mysql-shared
|
interface: mysql-shared
|
||||||
pgsql-db:
|
|
||||||
interface: pgsql
|
|
||||||
amqp:
|
amqp:
|
||||||
interface: rabbitmq
|
interface: rabbitmq
|
||||||
identity-service:
|
identity-service:
|
||||||
|
@ -69,7 +69,6 @@ TO_PATCH = [
|
|||||||
'is_clustered',
|
'is_clustered',
|
||||||
'is_elected_leader',
|
'is_elected_leader',
|
||||||
'is_qos_requested_and_valid',
|
'is_qos_requested_and_valid',
|
||||||
'is_relation_made',
|
|
||||||
'log',
|
'log',
|
||||||
'migrate_neutron_database',
|
'migrate_neutron_database',
|
||||||
'neutron_ready',
|
'neutron_ready',
|
||||||
@ -339,7 +338,6 @@ class NeutronAPIHooksTests(CharmTestCase):
|
|||||||
self.assertTrue(self.CONFIGS.write.called_with(NEUTRON_CONF))
|
self.assertTrue(self.CONFIGS.write.called_with(NEUTRON_CONF))
|
||||||
|
|
||||||
def test_db_joined(self):
|
def test_db_joined(self):
|
||||||
self.is_relation_made.return_value = False
|
|
||||||
self.get_relation_ip.return_value = '10.0.0.1'
|
self.get_relation_ip.return_value = '10.0.0.1'
|
||||||
self._call_hook('shared-db-relation-joined')
|
self._call_hook('shared-db-relation-joined')
|
||||||
self.relation_set.assert_called_with(
|
self.relation_set.assert_called_with(
|
||||||
@ -350,7 +348,6 @@ class NeutronAPIHooksTests(CharmTestCase):
|
|||||||
|
|
||||||
def test_db_joined_spaces(self):
|
def test_db_joined_spaces(self):
|
||||||
self.get_relation_ip.return_value = '192.168.20.1'
|
self.get_relation_ip.return_value = '192.168.20.1'
|
||||||
self.is_relation_made.return_value = False
|
|
||||||
self.unit_get.return_value = 'myhostname'
|
self.unit_get.return_value = 'myhostname'
|
||||||
self._call_hook('shared-db-relation-joined')
|
self._call_hook('shared-db-relation-joined')
|
||||||
self.relation_set.assert_called_with(
|
self.relation_set.assert_called_with(
|
||||||
@ -359,24 +356,6 @@ class NeutronAPIHooksTests(CharmTestCase):
|
|||||||
hostname='192.168.20.1',
|
hostname='192.168.20.1',
|
||||||
)
|
)
|
||||||
|
|
||||||
def test_db_joined_with_postgresql(self):
|
|
||||||
self.is_relation_made.return_value = True
|
|
||||||
with self.assertRaises(Exception):
|
|
||||||
hooks.db_joined()
|
|
||||||
|
|
||||||
def test_postgresql_db_joined(self):
|
|
||||||
self.unit_get.return_value = 'myhostname'
|
|
||||||
self.is_relation_made.return_value = False
|
|
||||||
self._call_hook('pgsql-db-relation-joined')
|
|
||||||
self.relation_set.assert_called_with(
|
|
||||||
database='neutron',
|
|
||||||
)
|
|
||||||
|
|
||||||
def test_postgresql_joined_with_db(self):
|
|
||||||
self.is_relation_made.return_value = True
|
|
||||||
with self.assertRaises(Exception):
|
|
||||||
hooks.pgsql_neutron_db_joined()
|
|
||||||
|
|
||||||
@patch.object(hooks, 'neutron_plugin_api_subordinate_relation_joined')
|
@patch.object(hooks, 'neutron_plugin_api_subordinate_relation_joined')
|
||||||
@patch.object(hooks, 'conditional_neutron_migration')
|
@patch.object(hooks, 'conditional_neutron_migration')
|
||||||
def test_shared_db_changed(self, cond_neutron_mig, plugin_joined):
|
def test_shared_db_changed(self, cond_neutron_mig, plugin_joined):
|
||||||
@ -394,17 +373,6 @@ class NeutronAPIHooksTests(CharmTestCase):
|
|||||||
self._call_hook('shared-db-relation-changed')
|
self._call_hook('shared-db-relation-changed')
|
||||||
self.assertFalse(self.CONFIGS.write_all.called)
|
self.assertFalse(self.CONFIGS.write_all.called)
|
||||||
|
|
||||||
@patch.object(hooks, 'neutron_plugin_api_subordinate_relation_joined')
|
|
||||||
@patch.object(hooks, 'conditional_neutron_migration')
|
|
||||||
def test_pgsql_db_changed(self, cond_neutron_mig, plugin_joined):
|
|
||||||
self.relation_ids.return_value = ['neutron-plugin-api-subordinate:1']
|
|
||||||
self._call_hook('pgsql-db-relation-changed')
|
|
||||||
self.assertTrue(self.CONFIGS.write.called)
|
|
||||||
cond_neutron_mig.assert_called_with()
|
|
||||||
self.relation_ids.assert_called_with('neutron-plugin-api-subordinate')
|
|
||||||
plugin_joined.assert_called_with(
|
|
||||||
relid='neutron-plugin-api-subordinate:1')
|
|
||||||
|
|
||||||
def test_amqp_broken(self):
|
def test_amqp_broken(self):
|
||||||
self._call_hook('amqp-relation-broken')
|
self._call_hook('amqp-relation-broken')
|
||||||
self.assertTrue(self.CONFIGS.write_all.called)
|
self.assertTrue(self.CONFIGS.write_all.called)
|
||||||
@ -496,7 +464,6 @@ class NeutronAPIHooksTests(CharmTestCase):
|
|||||||
self.relation_ids.side_effect = self._fake_relids
|
self.relation_ids.side_effect = self._fake_relids
|
||||||
_canonical_url.return_value = host
|
_canonical_url.return_value = host
|
||||||
self.api_port.return_value = port
|
self.api_port.return_value = port
|
||||||
self.is_relation_made = False
|
|
||||||
neutron_url = '%s:%s' % (host, port)
|
neutron_url = '%s:%s' % (host, port)
|
||||||
_relation_data = {
|
_relation_data = {
|
||||||
'enable-sriov': False,
|
'enable-sriov': False,
|
||||||
@ -528,7 +495,6 @@ class NeutronAPIHooksTests(CharmTestCase):
|
|||||||
_canonical_url.return_value = host
|
_canonical_url.return_value = host
|
||||||
self.api_port.return_value = port
|
self.api_port.return_value = port
|
||||||
self.get_dns_domain.return_value = ""
|
self.get_dns_domain.return_value = ""
|
||||||
self.is_relation_made = True
|
|
||||||
neutron_url = '%s:%s' % (host, port)
|
neutron_url = '%s:%s' % (host, port)
|
||||||
_relation_data = {
|
_relation_data = {
|
||||||
'enable-sriov': False,
|
'enable-sriov': False,
|
||||||
|
Loading…
Reference in New Issue
Block a user