Cover code changes in the vip_reservation
Cover: -case with empty namespace in network_roles.yaml -case with custom name of namespace Change-Id: Ia311a5d02e303093389f1cd9c464915c86531360 Closes-Bug:#1489608
This commit is contained in:
Egor Kotko
parent
73ed8d7c84
commit
11a4620439
@ -1,14 +1,14 @@
|
||||
- id: "reserved_vip_public"
|
||||
- id: "network_role_public"
|
||||
default_mapping: "public"
|
||||
properties:
|
||||
subnet: true
|
||||
gateway: false
|
||||
vip:
|
||||
- name: "reserved_vip_pub"
|
||||
- id: "reserved_vip_management"
|
||||
- name: "reserved_pub"
|
||||
- id: "network_role_management"
|
||||
default_mapping: "management"
|
||||
properties:
|
||||
subnet: true
|
||||
gateway: false
|
||||
vip:
|
||||
- name: "reserved_vip_mng"
|
||||
- name: "reserved_mng"
|
||||
@ -12,6 +12,7 @@
|
||||
# License for the specific language governing permissions and limitations
|
||||
# under the License.
|
||||
|
||||
import json
|
||||
import os
|
||||
|
||||
from proboscis import asserts
|
||||
@ -25,7 +26,6 @@ from fuelweb_test.tests.base_test_case import SetupEnvironment
|
||||
from fuelweb_test.tests.base_test_case import TestBasic
|
||||
from fuelweb_test.helpers.fuel_actions import FuelPluginBuilder
|
||||
from fuelweb_test.helpers.decorators import log_snapshot_after_test
|
||||
from proboscis.asserts import assert_equal
|
||||
|
||||
|
||||
@test(groups=["fuel_plugins", "fuel_plugin_vip_reservation"])
|
||||
@ -38,7 +38,7 @@ class VipReservation(TestBasic):
|
||||
"vip_reservation_for_plugin_vxlan"])
|
||||
@log_snapshot_after_test
|
||||
def vip_reservation_for_plugin(self):
|
||||
"""Check vip reservation for fuel plugin.
|
||||
"""Check vip reservation for fuel plugin
|
||||
|
||||
Scenario:
|
||||
1. Revert snapshot with 3 nodes
|
||||
@ -58,35 +58,36 @@ class VipReservation(TestBasic):
|
||||
tasks_file = 'tasks.yaml'
|
||||
net_role_file = 'network_roles.yaml'
|
||||
metadata_file = 'metadata.yaml'
|
||||
namespace = 'haproxy'
|
||||
|
||||
self.env.revert_snapshot("ready_with_3_slaves")
|
||||
with self.env.d_env.get_admin_remote() as admin_remote:
|
||||
# initiate fuel plugin builder instance
|
||||
fpb = FuelPluginBuilder(admin_remote)
|
||||
# install fuel_plugin_builder on master node
|
||||
fpb.fpb_install()
|
||||
# create plugin template on the master node
|
||||
fpb.fpb_create_plugin(plugin_name)
|
||||
# replace plugin tasks, metadata, network_roles
|
||||
fpb.fpb_replace_plugin_content(
|
||||
os.path.join(dir_path, net_role_file),
|
||||
os.path.join('/root/', plugin_name, net_role_file))
|
||||
fpb.fpb_replace_plugin_content(
|
||||
os.path.join(dir_path, tasks_file),
|
||||
os.path.join('/root/', plugin_name, tasks_file))
|
||||
fpb.fpb_replace_plugin_content(
|
||||
os.path.join(dir_path, metadata_file),
|
||||
os.path.join('/root/', plugin_name, metadata_file))
|
||||
# build plugin
|
||||
fpb.fpb_build_plugin(os.path.join('/root/', plugin_name))
|
||||
# copy plugin archive file from nailgun container
|
||||
# to the /var directory on the master node
|
||||
fpb.fpb_copy_plugin_from_container(plugin_name, plugin_path)
|
||||
# let's install plugin
|
||||
checkers.install_plugin_check_code(
|
||||
admin_remote,
|
||||
plugin=os.path.join(plugin_path, '{}.rpm'.format(plugin_name)))
|
||||
|
||||
admin_remote = self.env.d_env.get_admin_remote()
|
||||
# initiate fuel plugin builder instance
|
||||
fpb = FuelPluginBuilder(admin_remote)
|
||||
# install fuel_plugin_builder on master node
|
||||
fpb.fpb_install()
|
||||
# create plugin template on the master node
|
||||
fpb.fpb_create_plugin(plugin_name)
|
||||
# replace plugin tasks, metadata, network_roles
|
||||
fpb.fpb_replace_plugin_content(
|
||||
os.path.join(dir_path, net_role_file),
|
||||
os.path.join('/root/', plugin_name, net_role_file))
|
||||
fpb.fpb_replace_plugin_content(
|
||||
os.path.join(dir_path, tasks_file),
|
||||
os.path.join('/root/', plugin_name, tasks_file))
|
||||
fpb.fpb_replace_plugin_content(
|
||||
os.path.join(dir_path, metadata_file),
|
||||
os.path.join('/root/', plugin_name, metadata_file))
|
||||
# build plugin
|
||||
fpb.fpb_build_plugin(os.path.join('/root/', plugin_name))
|
||||
# copy plugin archive file from nailgun container
|
||||
# to the /var directory on the master node
|
||||
fpb.fpb_copy_plugin_from_container(plugin_name, plugin_path)
|
||||
# let's install plugin
|
||||
checkers.install_plugin_check_code(
|
||||
admin_remote,
|
||||
plugin=os.path.join(plugin_path, '{}.rpm'.format(plugin_name)))
|
||||
cluster_id = self.fuel_web.create_cluster(
|
||||
name=self.__class__.__name__,
|
||||
mode=DEPLOYMENT_MODE,
|
||||
@ -115,25 +116,284 @@ class VipReservation(TestBasic):
|
||||
|
||||
self.fuel_web.run_ostf(cluster_id=cluster_id)
|
||||
|
||||
remote = self.fuel_web.get_ssh_for_node('slave-01')
|
||||
# get vips from hiera
|
||||
reserved_vip_pub = remote.execute(
|
||||
'hiera reserved_vip_pub')['stdout'][1].split('"')[3]
|
||||
reserved_vip_mng = remote.execute(
|
||||
'hiera reserved_vip_mng')['stdout'][1].split('"')[3]
|
||||
# get vips from database
|
||||
reserved_vip_pub_db = self.env.postgres_actions.run_query(
|
||||
db='nailgun', query="select ip_addr from ip_addrs where "
|
||||
"vip_type = '\"'\"'reserved_vip_pub'\"'\"';")
|
||||
reserved_vip_mng_db = self.env.postgres_actions.run_query(
|
||||
db='nailgun', query="select ip_addr from ip_addrs where "
|
||||
"vip_type = '\"'\"'reserved_vip_mng'\"'\"';")
|
||||
with self.fuel_web.get_ssh_for_node('slave-01') as remote:
|
||||
hiera_json_out = "ruby -rhiera -rjson -e \"h = Hiera.new(); " \
|
||||
"Hiera.logger = 'noop'; puts JSON.dump " \
|
||||
"(h.lookup('network_metadata', " \
|
||||
"[], {}, nil, nil))\""
|
||||
for vip in ('reserved_pub', 'reserved_mng'):
|
||||
# get vips from hiera
|
||||
vip_hiera = json.loads(
|
||||
remote.execute(
|
||||
hiera_json_out)['stdout'][0])["vips"][vip]["ipaddr"]
|
||||
# get vips from database
|
||||
vip_db = self.env.postgres_actions.run_query(
|
||||
db='nailgun',
|
||||
query="select ip_addr from ip_addrs where "
|
||||
"vip_type = '\"'\"'{0}'\"'\"';".format(vip))
|
||||
vip_array = [vip_hiera, vip_db]
|
||||
for ip in vip_array[1:]:
|
||||
asserts.assert_equal(
|
||||
vip_array[0], ip,
|
||||
"Vip from hiera output {0} does not equal "
|
||||
"to {1}".format(vip_array[0], ip))
|
||||
vip_pcs = remote.execute(
|
||||
'pcs resource show {0}{1}'.format(
|
||||
'vip__', vip))['exit_code']
|
||||
asserts.assert_not_equal(0, vip_pcs,
|
||||
'The vip__{0} was found in '
|
||||
'pacemaker'.format(vip))
|
||||
vip_ns = remote.execute(
|
||||
'ip netns exec {0} ip a | grep {1}{2}'.format(
|
||||
namespace, 'b_', vip))['exit_code']
|
||||
asserts.assert_not_equal(0, vip_ns,
|
||||
'The {0} was found in {1} '
|
||||
'namespace'.format(vip, namespace))
|
||||
|
||||
assert_equal(reserved_vip_pub, reserved_vip_pub_db,
|
||||
"Vip public from hiera output {0} does not equal to "
|
||||
"vip public from database {1}".format(
|
||||
reserved_vip_pub, reserved_vip_pub_db))
|
||||
assert_equal(reserved_vip_mng, reserved_vip_mng_db,
|
||||
"Vip management from hiera output {0} does not equal to "
|
||||
"vip management from database {1}".format(
|
||||
reserved_vip_mng, reserved_vip_mng_db))
|
||||
@test(depends_on=[SetupEnvironment.prepare_slaves_3],
|
||||
groups=["vip_reservation_for_plugin_haproxy_ns",
|
||||
"vip_reservation_for_plugin_haproxy_ns_vlan",
|
||||
"vip_reservation_for_plugin_haproxy_ns_vxlan"])
|
||||
@log_snapshot_after_test
|
||||
def vip_reservation_for_plugin_haproxy_ns(self):
|
||||
"""Check vip reservation for fuel plugin
|
||||
|
||||
Scenario:
|
||||
1. Revert snapshot with 3 nodes
|
||||
2. Download and install fuel-plugin-builder
|
||||
3. Create plugin with predefined network_roles.yaml
|
||||
4. Build and copy plugin from container nailgun
|
||||
5. Install plugin to fuel
|
||||
6. Create cluster and enable plugin
|
||||
7. Deploy cluster
|
||||
8. Check vip reservation
|
||||
|
||||
Duration 40m
|
||||
"""
|
||||
plugin_name = 'vip_reservation_plugin'
|
||||
plugin_path = '/var'
|
||||
task_path = os.path.dirname(os.path.abspath(__file__))
|
||||
tasks_file = 'tasks.yaml'
|
||||
net_role_file = 'network_roles.yaml'
|
||||
metadata_file = 'metadata.yaml'
|
||||
namespace = 'haproxy'
|
||||
|
||||
self.env.revert_snapshot("ready_with_3_slaves")
|
||||
|
||||
with self.env.d_env.get_admin_remote() as admin_remote:
|
||||
# initiate fuel plugin builder instance
|
||||
fpb = FuelPluginBuilder(admin_remote)
|
||||
# install fuel_plugin_builder on master node
|
||||
fpb.fpb_install()
|
||||
# create plugin template on the master node
|
||||
fpb.change_content_in_yaml(
|
||||
os.path.join(task_path, net_role_file), os.path.join(
|
||||
'/tmp/', net_role_file), [0, 'properties', 'vip', 0,
|
||||
'namespace'], namespace)
|
||||
fpb.change_content_in_yaml(
|
||||
os.path.join('/tmp/', net_role_file), os.path.join(
|
||||
'/tmp/', net_role_file), [1, 'properties', 'vip', 0,
|
||||
'namespace'], namespace)
|
||||
fpb.fpb_create_plugin(plugin_name)
|
||||
# replace plugin tasks, metadata, network_roles
|
||||
fpb.fpb_replace_plugin_content(
|
||||
os.path.join('/tmp/', net_role_file),
|
||||
os.path.join('/root/', plugin_name, net_role_file))
|
||||
fpb.fpb_replace_plugin_content(
|
||||
os.path.join(task_path, tasks_file),
|
||||
os.path.join('/root/', plugin_name, tasks_file))
|
||||
fpb.fpb_replace_plugin_content(
|
||||
os.path.join(task_path, metadata_file),
|
||||
os.path.join('/root/', plugin_name, metadata_file))
|
||||
# build plugin
|
||||
fpb.fpb_build_plugin(os.path.join('/root/', plugin_name))
|
||||
# copy plugin archive file from nailgun container
|
||||
# to the /var directory on the master node
|
||||
fpb.fpb_copy_plugin_from_container(plugin_name, plugin_path)
|
||||
# let's install plugin
|
||||
checkers.install_plugin_check_code(
|
||||
admin_remote,
|
||||
plugin=os.path.join(plugin_path, '{}.rpm'.format(plugin_name)))
|
||||
|
||||
cluster_id = self.fuel_web.create_cluster(
|
||||
name=self.__class__.__name__,
|
||||
mode=DEPLOYMENT_MODE,
|
||||
settings={
|
||||
"net_provider": 'neutron',
|
||||
"net_segment_type": NEUTRON_SEGMENT_TYPE
|
||||
}
|
||||
)
|
||||
# get plugins from fuel and enable our one
|
||||
msg = "Plugin couldn't be enabled. Check plugin version. Test aborted"
|
||||
asserts.assert_true(
|
||||
self.fuel_web.check_plugin_exists(cluster_id, plugin_name),
|
||||
msg)
|
||||
options = {'metadata/enabled': True}
|
||||
self.fuel_web.update_plugin_data(cluster_id, plugin_name, options)
|
||||
|
||||
logger.info('cluster is %s' % str(cluster_id))
|
||||
|
||||
self.fuel_web.update_nodes(
|
||||
cluster_id,
|
||||
{
|
||||
'slave-01': ['controller'],
|
||||
'slave-02': ['compute']}
|
||||
)
|
||||
self.fuel_web.deploy_cluster_wait(cluster_id)
|
||||
|
||||
self.fuel_web.run_ostf(cluster_id=cluster_id)
|
||||
|
||||
with self.fuel_web.get_ssh_for_node('slave-01') as remote:
|
||||
hiera_json_out = "ruby -rhiera -rjson -e \"h = Hiera.new(); " \
|
||||
"Hiera.logger = 'noop'; " \
|
||||
"puts JSON.dump(h.lookup('network_metadata', " \
|
||||
"[], {}, nil, nil))\""
|
||||
for vip in ('reserved_pub', 'reserved_mng'):
|
||||
# get vips from hiera
|
||||
vip_hiera = json.loads(
|
||||
remote.execute(
|
||||
hiera_json_out)['stdout'][0])["vips"][vip]["ipaddr"]
|
||||
# get vips from database
|
||||
vip_db = self.env.postgres_actions.run_query(
|
||||
db='nailgun',
|
||||
query="select ip_addr from ip_addrs where "
|
||||
"vip_type = '\"'\"'{0}'\"'\"';".format(vip))
|
||||
# get vips from pacemaker
|
||||
vip_pcs = remote.execute(
|
||||
'pcs resource show {0}{1}'.format(
|
||||
'vip__', vip))['stdout'][1].split(' ')[6].split('=')[1]
|
||||
# fet vips from namespace
|
||||
vip_ns = remote.execute(
|
||||
'ip netns exec {0} ip -4 a show {1}{2}'.format(
|
||||
namespace, 'b_',
|
||||
vip))['stdout'][1].split(' ')[5].split('/')[0]
|
||||
vip_array = [vip_hiera, vip_db, vip_pcs, vip_ns]
|
||||
for ip in vip_array[1:]:
|
||||
asserts.assert_equal(
|
||||
vip_array[0], ip,
|
||||
"Vip from hiera output {0} does not equal "
|
||||
"to {1}".format(vip_array[0], ip))
|
||||
|
||||
@test(depends_on=[SetupEnvironment.prepare_slaves_3],
|
||||
groups=["vip_reservation_for_plugin_custom_ns",
|
||||
"vip_reservation_for_plugin_custom_ns_vlan",
|
||||
"vip_reservation_for_plugin_custom_ns_vxlan"])
|
||||
@log_snapshot_after_test
|
||||
def vip_reservation_for_plugin_custom_ns(self):
|
||||
"""Check vip reservation for fuel plugin
|
||||
|
||||
Scenario:
|
||||
1. Revert snapshot with 3 nodes
|
||||
2. Download and install fuel-plugin-builder
|
||||
3. Create plugin with predefined network_roles.yaml
|
||||
4. Build and copy plugin from container nailgun
|
||||
5. Install plugin to fuel
|
||||
6. Create cluster and enable plugin
|
||||
7. Deploy cluster
|
||||
8. Check vip reservation
|
||||
|
||||
Duration 40m
|
||||
"""
|
||||
plugin_name = 'vip_reservation_plugin'
|
||||
plugin_path = '/var'
|
||||
task_path = os.path.dirname(os.path.abspath(__file__))
|
||||
tasks_file = 'tasks.yaml'
|
||||
net_role_file = 'network_roles.yaml'
|
||||
metadata_file = 'metadata.yaml'
|
||||
namespace = 'custom_ns'
|
||||
|
||||
self.env.revert_snapshot("ready_with_3_slaves")
|
||||
|
||||
with self.env.d_env.get_admin_remote() as admin_remote:
|
||||
# initiate fuel plugin builder instance
|
||||
fpb = FuelPluginBuilder(admin_remote)
|
||||
fpb.change_content_in_yaml(
|
||||
os.path.join(task_path, net_role_file),
|
||||
os.path.join('/tmp/', net_role_file),
|
||||
[0, 'properties', 'vip', 0, 'namespace'], namespace)
|
||||
fpb.change_content_in_yaml(
|
||||
os.path.join('/tmp/', net_role_file),
|
||||
os.path.join('/tmp/', net_role_file),
|
||||
[1, 'properties', 'vip', 0, 'namespace'], namespace)
|
||||
# install fuel_plugin_builder on master node
|
||||
fpb.fpb_install()
|
||||
# create plugin template on the master node
|
||||
fpb.fpb_create_plugin(plugin_name)
|
||||
# replace plugin tasks, metadata, network_roles
|
||||
fpb.fpb_replace_plugin_content(
|
||||
os.path.join('/tmp/', net_role_file),
|
||||
os.path.join('/root/', plugin_name, net_role_file))
|
||||
fpb.fpb_replace_plugin_content(
|
||||
os.path.join(task_path, tasks_file),
|
||||
os.path.join('/root/', plugin_name, tasks_file))
|
||||
fpb.fpb_replace_plugin_content(
|
||||
os.path.join(task_path, metadata_file),
|
||||
os.path.join('/root/', plugin_name, metadata_file))
|
||||
# build plugin
|
||||
fpb.fpb_build_plugin(os.path.join('/root/', plugin_name))
|
||||
# copy plugin archive file from nailgun container
|
||||
# to the /var directory on the master node
|
||||
fpb.fpb_copy_plugin_from_container(plugin_name, plugin_path)
|
||||
# let's install plugin
|
||||
checkers.install_plugin_check_code(
|
||||
admin_remote,
|
||||
plugin=os.path.join(plugin_path, '{}.rpm'.format(plugin_name)))
|
||||
|
||||
cluster_id = self.fuel_web.create_cluster(
|
||||
name=self.__class__.__name__,
|
||||
mode=DEPLOYMENT_MODE,
|
||||
settings={
|
||||
"net_provider": 'neutron',
|
||||
"net_segment_type": NEUTRON_SEGMENT_TYPE
|
||||
}
|
||||
)
|
||||
# get plugins from fuel and enable our one
|
||||
msg = "Plugin couldn't be enabled. Check plugin version. Test aborted"
|
||||
asserts.assert_true(
|
||||
self.fuel_web.check_plugin_exists(cluster_id, plugin_name),
|
||||
msg)
|
||||
options = {'metadata/enabled': True}
|
||||
self.fuel_web.update_plugin_data(cluster_id, plugin_name, options)
|
||||
|
||||
logger.info('cluster is %s' % str(cluster_id))
|
||||
|
||||
self.fuel_web.update_nodes(
|
||||
cluster_id,
|
||||
{
|
||||
'slave-01': ['controller'],
|
||||
'slave-02': ['compute']}
|
||||
)
|
||||
self.fuel_web.deploy_cluster_wait(cluster_id)
|
||||
|
||||
self.fuel_web.run_ostf(cluster_id=cluster_id)
|
||||
|
||||
with self.fuel_web.get_ssh_for_node('slave-01') as remote:
|
||||
hiera_json_out = "ruby -rhiera -rjson -e \"h = Hiera.new(); " \
|
||||
"Hiera.logger = 'noop'; " \
|
||||
"puts JSON.dump(h.lookup('network_metadata', " \
|
||||
"[], {}, nil, nil))\""
|
||||
for vip in ('reserved_pub', 'reserved_mng'):
|
||||
# get vips from hiera
|
||||
vip_hiera = json.loads(
|
||||
remote.execute(
|
||||
hiera_json_out)['stdout'][0])["vips"][vip]["ipaddr"]
|
||||
# get vips from database
|
||||
vip_db = self.env.postgres_actions.run_query(
|
||||
db='nailgun',
|
||||
query="select ip_addr from ip_addrs where "
|
||||
"vip_type = '\"'\"'{0}'\"'\"';".format(vip))
|
||||
# get vips from pacemaker
|
||||
vip_pcs = remote.execute(
|
||||
'pcs resource show {0}{1}'.format(
|
||||
'vip__', vip))['stdout'][1].split(' ')[6].split('=')[1]
|
||||
# get vips from namespace
|
||||
vip_ns = remote.execute(
|
||||
'ip netns exec {0} ip -4 a show {1}{2}'.format(
|
||||
namespace, 'b_',
|
||||
vip))['stdout'][1].split(' ')[5].split('/')[0]
|
||||
vip_array = [vip_hiera, vip_db, vip_pcs, vip_ns]
|
||||
for ip in vip_array[1:]:
|
||||
asserts.assert_equal(
|
||||
vip_array[0], ip,
|
||||
"Vip from hiera output {0} does not equal "
|
||||
"to {1}".format(vip_array[0], ip))
|
||||
|
||||
Loading…
Reference in New Issue
Block a user