Merge "[cli] Introduce "rally plugin" show and list commands"

This commit is contained in:
Jenkins 2015-09-17 05:32:33 +00:00 committed by Gerrit Code Review
commit 2064dc9298
6 changed files with 87 additions and 7 deletions

View File

@ -32,6 +32,8 @@ _rally()
OPTS["info_ServerProviders"]="" OPTS["info_ServerProviders"]=""
OPTS["info_find"]="--query" OPTS["info_find"]="--query"
OPTS["info_list"]="" OPTS["info_list"]=""
OPTS["plugin_list"]="--name --namespace"
OPTS["plugin_show"]="--name --namespace"
OPTS["show_flavors"]="--deployment" OPTS["show_flavors"]="--deployment"
OPTS["show_images"]="--deployment" OPTS["show_images"]="--deployment"
OPTS["show_keypairs"]="--deployment" OPTS["show_keypairs"]="--deployment"

View File

@ -87,6 +87,7 @@ def _prepare_open_secgroup(endpoint, secgroup_name):
@context.configure(name="allow_ssh", order=320) @context.configure(name="allow_ssh", order=320)
class AllowSSH(context.Context): class AllowSSH(context.Context):
"""Sets up security groups for all users to access VM via SSH."""
@utils.log_task_wrapper(LOG.info, _("Enter context: `allow_ssh`")) @utils.log_task_wrapper(LOG.info, _("Enter context: `allow_ssh`"))
def setup(self): def setup(self):

View File

@ -218,9 +218,8 @@ class CinderScenario(scenario.OpenStackScenario):
it's attached to an instance it's attached to an instance
:param container_format: container format of image. Acceptable :param container_format: container format of image. Acceptable
formats: ami, ari, aki, bare, and ovf formats: ami, ari, aki, bare, and ovf
:param: disk_format: disk format of image. Acceptable formats: :param disk_format: disk format of image. Acceptable formats:
ami, ari, aki, vhd, vmdk, raw, qcow2, vdi ami, ari, aki, vhd, vmdk, raw, qcow2, vdi and iso
and iso
:returns: Returns created image object :returns: Returns created image object
""" """
resp, img = volume.upload_to_image(force, self._generate_random_name(), resp, img = volume.upload_to_image(force, self._generate_random_name(),

View File

@ -411,7 +411,7 @@ class SaharaScenario(scenario.OpenStackScenario):
def _create_output_ds(self): def _create_output_ds(self):
"""Create an output Data Source based on EDP context """Create an output Data Source based on EDP context
:return: The created Data Source :returns: The created Data Source
""" """
ds_type = self.context["sahara_output_conf"]["output_type"] ds_type = self.context["sahara_output_conf"]["output_type"]
url_prefix = self.context["sahara_output_conf"]["output_url_prefix"] url_prefix = self.context["sahara_output_conf"]["output_url_prefix"]
@ -502,7 +502,7 @@ class SaharaScenario(scenario.OpenStackScenario):
If Nova Network is used as networking backend, None is returned. If Nova Network is used as networking backend, None is returned.
:return: Network id for Neutron or None for Nova Networking. :returns: Network id for Neutron or None for Nova Networking.
""" """
if consts.Service.NEUTRON not in self.clients("services").values(): if consts.Service.NEUTRON not in self.clients("services").values():

View File

@ -370,7 +370,7 @@ class NeutronWrapper(NetworkWrapper):
"""Create Neutron floating IP. """Create Neutron floating IP.
:param ext_network: floating network name or dict :param ext_network: floating network name or dict
:param tenant_id str tenant id :param tenant_id: str tenant id
:param port_id: str port id :param port_id: str port id
:param **kwargs: for compatibility, not used here :param **kwargs: for compatibility, not used here
:returns: floating IP dict :returns: floating IP dict
@ -415,7 +415,7 @@ class NeutronWrapper(NetworkWrapper):
"""Check whether a neutron extension is supported """Check whether a neutron extension is supported
:param extension: str, neutron extension :param extension: str, neutron extension
:return: result tuple :returns: result tuple
:rtype: (bool, string) :rtype: (bool, string)
""" """
extensions = self.client.list_extensions().get("extensions", []) extensions = self.client.list_extensions().get("extensions", [])

View File

@ -0,0 +1,78 @@
# Copyright 2015: Mirantis Inc.
# All Rights Reserved.
#
# 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 unittest
from tests.functional import utils
class PluginTestCase(unittest.TestCase):
def setUp(self):
super(PluginTestCase, self).setUp()
self.rally = utils.Rally()
def test_show_one(self):
result = self.rally("plugin show Dummy.dummy_with_scenario_output")
self.assertIn("NAME", result)
self.assertIn("NAMESPACE", result)
self.assertIn("Dummy.dummy_with_scenario_output", result)
self.assertIn("MODULE", result)
def test_show_multiple_and_full_match(self):
result = self.rally("plugin show Dummy.dummy")
self.assertIn("NAME", result)
self.assertIn("NAMESPACE", result)
self.assertIn("Dummy.dummy", result)
self.assertIn("MODULE", result)
def test_show_multiple(self):
result = self.rally("plugin show Dummy")
self.assertIn("Multiple plugins found:", result)
self.assertIn("Dummy.dummy", result)
self.assertIn("Dummy.dummy_exception", result)
self.assertIn("Dummy.dummy_with_scenario_output", result)
self.assertIn("Dummy.dummy_random_fail_in_atomic", result)
def test_show_not_found(self):
name = "Dummy666666"
result = self.rally("plugin show %s" % name)
self.assertIn("There is no plugin: %s" % name, result)
def test_show_not_found_in_specific_namespace(self):
name = "Dummy"
namespace = "non_existing"
result = self.rally(
"plugin show --name %(name)s --namespace %(namespace)s"
% {"name": name, "namespace": namespace})
self.assertIn(
"There is no plugin: %(name)s in %(namespace)s namespace"
% {"name": name, "namespace": namespace},
result)
def test_list(self):
result = self.rally("plugin list Dummy")
self.assertIn("Dummy.dummy", result)
self.assertIn("Dummy.dummy_exception", result)
self.assertIn("Dummy.dummy_with_scenario_output", result)
self.assertIn("Dummy.dummy_random_fail_in_atomic", result)
def test_list_not_found_namespace(self):
result = self.rally("plugin list --namespace some")
self.assertIn("There is no plugin namespace: some", result)
def test_list_not_found_name(self):
result = self.rally("plugin list Dummy2222")
self.assertIn("There is no plugin: Dummy2222", result)