summaryrefslogtreecommitdiff
diff options
context:
space:
mode:
-rw-r--r--doc/source/cli/nova.rst22
-rw-r--r--novaclient/__init__.py2
-rw-r--r--novaclient/tests/unit/fixture_data/aggregates.py7
-rw-r--r--novaclient/tests/unit/v2/fakes.py16
-rw-r--r--novaclient/tests/unit/v2/test_aggregates.py40
-rw-r--r--novaclient/tests/unit/v2/test_shell.py48
-rw-r--r--novaclient/v2/aggregates.py22
-rw-r--r--novaclient/v2/images.py37
-rw-r--r--novaclient/v2/shell.py23
-rw-r--r--releasenotes/notes/microversion-v2_81-3ddd8e2fc7e45030.yaml10
10 files changed, 224 insertions, 3 deletions
diff --git a/doc/source/cli/nova.rst b/doc/source/cli/nova.rst
index b94e52af..fd8dbc4d 100644
--- a/doc/source/cli/nova.rst
+++ b/doc/source/cli/nova.rst
@@ -73,6 +73,9 @@ nova usage
``aggregate-add-host``
Add the host to the specified aggregate.
+``aggregate-cache-images``
+ Request images be pre-cached on hosts within an aggregate.
+
``aggregate-create``
Create a new aggregate with the specified
details.
@@ -756,6 +759,25 @@ Add the host to the specified aggregate.
``<host>``
The host to add to the aggregate.
+.. _nova_aggregate-cache-images:
+
+nova aggregate-cache-images
+---------------------------
+
+.. code-block:: console
+
+ usage: nova aggregate-cache-images <aggregate> <image> [<image> ..]
+
+Request image(s) be pre-cached on hosts within the aggregate.
+
+**Positional arguments:**
+
+``<aggregate>``
+ Name or ID of aggregate.
+
+``<image>``
+ Name or ID of image(s) to cache.
+
.. _nova_aggregate-create:
nova aggregate-create
diff --git a/novaclient/__init__.py b/novaclient/__init__.py
index c4f56fba..6855e2f2 100644
--- a/novaclient/__init__.py
+++ b/novaclient/__init__.py
@@ -25,4 +25,4 @@ API_MIN_VERSION = api_versions.APIVersion("2.1")
# when client supported the max version, and bumped sequentially, otherwise
# the client may break due to server side new version may include some
# backward incompatible change.
-API_MAX_VERSION = api_versions.APIVersion("2.80")
+API_MAX_VERSION = api_versions.APIVersion("2.81")
diff --git a/novaclient/tests/unit/fixture_data/aggregates.py b/novaclient/tests/unit/fixture_data/aggregates.py
index 3ea64b8b..b3ab88c5 100644
--- a/novaclient/tests/unit/fixture_data/aggregates.py
+++ b/novaclient/tests/unit/fixture_data/aggregates.py
@@ -51,3 +51,10 @@ class Fixture(base.Fixture):
self.requests_mock.delete(self.url(1), status_code=202,
headers=self.json_headers)
+
+ self.requests_mock.register_uri('POST', self.url(1),
+ json={},
+ headers=self.json_headers)
+ self.requests_mock.post(self.url(1, 'images'),
+ json={},
+ headers=self.json_headers)
diff --git a/novaclient/tests/unit/v2/fakes.py b/novaclient/tests/unit/v2/fakes.py
index 6302c116..62d5e727 100644
--- a/novaclient/tests/unit/v2/fakes.py
+++ b/novaclient/tests/unit/v2/fakes.py
@@ -1141,7 +1141,7 @@ class FakeSessionClient(base_client.SessionClient):
# Images
#
def get_images(self, **kw):
- return (200, {}, {'images': [
+ images = [
{
"id": FAKE_IMAGE_UUID_SNAPSHOT,
"name": "My Server Backup",
@@ -1191,7 +1191,16 @@ class FakeSessionClient(base_client.SessionClient):
"progress": 80,
"links": {},
},
- ]})
+ ]
+
+ if 'id' in kw:
+ requested = kw['id'].replace('in:', '').split(',')
+ images = [i for i in images if i['id'] in requested]
+ if 'names' in kw:
+ requested = kw['names'].replace('in:', '').split(',')
+ images = [i for i in images if i['name'] in requested]
+
+ return (200, {}, {'images': images})
def get_images_555cae93_fb41_4145_9c52_f5b923538a26(self, **kw):
return (200, {}, {'image': self.get_images()[2]['images'][0]})
@@ -1725,6 +1734,9 @@ class FakeSessionClient(base_client.SessionClient):
def delete_os_aggregates_1(self, **kw):
return (202, {}, None)
+ def post_os_aggregates_1_images(self, body, **kw):
+ return (202, {}, None)
+
#
# Services
#
diff --git a/novaclient/tests/unit/v2/test_aggregates.py b/novaclient/tests/unit/v2/test_aggregates.py
index 1de12823..4f3eecdf 100644
--- a/novaclient/tests/unit/v2/test_aggregates.py
+++ b/novaclient/tests/unit/v2/test_aggregates.py
@@ -13,11 +13,14 @@
# License for the specific language governing permissions and limitations
# under the License.
+from novaclient import api_versions
+from novaclient import exceptions
from novaclient.tests.unit.fixture_data import aggregates as data
from novaclient.tests.unit.fixture_data import client
from novaclient.tests.unit import utils
from novaclient.tests.unit.v2 import fakes
from novaclient.v2 import aggregates
+from novaclient.v2 import images
class AggregatesTest(utils.FixturedTestCase):
@@ -161,3 +164,40 @@ class AggregatesTest(utils.FixturedTestCase):
result3 = self.cs.aggregates.delete(aggregate)
self.assert_request_id(result3, fakes.FAKE_REQUEST_ID_LIST)
self.assert_called('DELETE', '/os-aggregates/1')
+
+
+class AggregatesV281Test(utils.FixturedTestCase):
+ api_version = "2.81"
+ data_fixture_class = data.Fixture
+
+ scenarios = [('original', {'client_fixture_class': client.V1}),
+ ('session', {'client_fixture_class': client.SessionV1})]
+
+ def setUp(self):
+ super(AggregatesV281Test, self).setUp()
+ self.cs.api_version = api_versions.APIVersion(self.api_version)
+
+ def test_cache_images(self):
+ aggregate = self.cs.aggregates.list()[0]
+ _images = [images.Image(self.cs.aggregates, {'id': '1'}),
+ images.Image(self.cs.aggregates, {'id': '2'})]
+ aggregate.cache_images(_images)
+ expected_body = {'cache': [{'id': image.id}
+ for image in _images]}
+ self.assert_called('POST', '/os-aggregates/1/images',
+ expected_body)
+
+ def test_cache_images_just_ids(self):
+ aggregate = self.cs.aggregates.list()[0]
+ _images = ['1']
+ aggregate.cache_images(_images)
+ expected_body = {'cache': [{'id': '1'}]}
+ self.assert_called('POST', '/os-aggregates/1/images',
+ expected_body)
+
+ def test_cache_images_pre281(self):
+ self.cs.api_version = api_versions.APIVersion('2.80')
+ aggregate = self.cs.aggregates.list()[0]
+ _images = [images.Image(self.cs.aggregates, {'id': '1'})]
+ self.assertRaises(exceptions.VersionNotFoundForAPIMethod,
+ aggregate.cache_images, _images)
diff --git a/novaclient/tests/unit/v2/test_shell.py b/novaclient/tests/unit/v2/test_shell.py
index 79118afc..b68254a2 100644
--- a/novaclient/tests/unit/v2/test_shell.py
+++ b/novaclient/tests/unit/v2/test_shell.py
@@ -2884,6 +2884,30 @@ class ShellTest(utils.TestCase):
self.run_command('aggregate-show test')
self.assert_called('GET', '/os-aggregates')
+ def test_aggregate_cache_images(self):
+ self.run_command(
+ 'aggregate-cache-images 1 %s %s' % (
+ FAKE_UUID_1, FAKE_UUID_2),
+ api_version='2.81')
+ body = {
+ 'cache': [{'id': FAKE_UUID_1},
+ {'id': FAKE_UUID_2}],
+ }
+ self.assert_called('POST', '/os-aggregates/1/images', body)
+
+ def test_aggregate_cache_images_no_images(self):
+ self.assertRaises(SystemExit,
+ self.run_command,
+ 'aggregate-cache-images 1',
+ api_version='2.81')
+
+ def test_aggregate_cache_images_pre281(self):
+ self.assertRaises(SystemExit,
+ self.run_command,
+ 'aggregate-cache-images 1 %s %s' % (
+ FAKE_UUID_1, FAKE_UUID_2),
+ api_version='2.80')
+
def test_live_migration(self):
self.run_command('live-migration sample-server hostname')
self.assert_called('POST', '/servers/1234/action',
@@ -4676,3 +4700,27 @@ class PollForStatusTestCase(utils.TestCase):
action=action,
show_progress=True,
silent=False)
+
+
+class TestUtilMethods(utils.TestCase):
+ def setUp(self):
+ super(TestUtilMethods, self).setUp()
+ self.shell = self.useFixture(ShellFixture()).shell
+ # NOTE(danms): Get a client that we can use to call things outside of
+ # the shell main
+ self.shell.cs = fakes.FakeClient('2.1')
+
+ def test_find_images(self):
+ """Test find_images() with a name and id."""
+ images = novaclient.v2.shell._find_images(self.shell.cs,
+ [FAKE_UUID_1,
+ 'back1'])
+ self.assertEqual(2, len(images))
+ self.assertEqual(FAKE_UUID_1, images[0].id)
+ self.assertEqual(fakes.FAKE_IMAGE_UUID_BACKUP, images[1].id)
+
+ def test_find_images_missing(self):
+ """Test find_images() where one of the images is not found."""
+ self.assertRaises(exceptions.CommandError,
+ novaclient.v2.shell._find_images,
+ self.shell.cs, [FAKE_UUID_1, 'foo'])
diff --git a/novaclient/v2/aggregates.py b/novaclient/v2/aggregates.py
index 9d4dff82..d2cbaa85 100644
--- a/novaclient/v2/aggregates.py
+++ b/novaclient/v2/aggregates.py
@@ -15,6 +15,7 @@
"""Aggregate interface."""
+from novaclient import api_versions
from novaclient import base
@@ -45,6 +46,10 @@ class Aggregate(base.Resource):
"""
return self.manager.delete(self)
+ @api_versions.wraps("2.81")
+ def cache_images(self, images):
+ return self.manager.cache_images(self, images)
+
class AggregateManager(base.ManagerWithFind):
resource_class = Aggregate
@@ -103,3 +108,20 @@ class AggregateManager(base.ManagerWithFind):
:returns: An instance of novaclient.base.TupleWithMeta
"""
return self._delete('/os-aggregates/%s' % (base.getid(aggregate)))
+
+ @api_versions.wraps("2.81")
+ def cache_images(self, aggregate, images):
+ """
+ Request images be cached on a given aggregate.
+
+ :param aggregate: The aggregate to target
+ :param images: A list of image IDs to request caching
+ :returns: An instance of novaclient.base.TupleWithMeta
+ """
+ body = {
+ 'cache': [{'id': base.getid(image)} for image in images],
+ }
+ resp, body = self.api.client.post(
+ "/os-aggregates/%s/images" % base.getid(aggregate),
+ body=body)
+ return self.convert_into_with_meta(body, resp)
diff --git a/novaclient/v2/images.py b/novaclient/v2/images.py
index e83d9b2f..0aced5c7 100644
--- a/novaclient/v2/images.py
+++ b/novaclient/v2/images.py
@@ -66,6 +66,43 @@ class GlanceManager(base.Manager):
matches[0].append_request_ids(matches.request_ids)
return matches[0]
+ def find_images(self, names_or_ids):
+ """Find multiple images by name or id (user provided input).
+
+ :param names_or_ids: A list of strings to use to find images.
+ :returns: novaclient.v2.images.Image objects for each images found
+ :raises exceptions.NotFound: If one or more images is not found
+ :raises exceptions.ClientException: If the image service returns any
+ unexpected images.
+
+ NOTE: This method always makes two calls to the image service, even if
+ only one image is provided by ID and is returned in the first query.
+ """
+ with self.alternate_service_type(
+ 'image', allowed_types=('image',)):
+ matches = self._list('/v2/images?id=in:%s' % ','.join(
+ names_or_ids), 'images')
+ matches.extend(self._list('/v2/images?names=in:%s' % ','.join(
+ names_or_ids), 'images'))
+ missed = (set(names_or_ids) -
+ set(m.name for m in matches) -
+ set(m.id for m in matches))
+ if missed:
+ msg = _("Unable to find image(s): %(images)s") % {
+ "images": ",".join(missed)}
+ raise exceptions.NotFound(404, msg)
+ for match in matches:
+ match.append_request_ids(matches.request_ids)
+
+ additional = []
+ for i in matches:
+ if i.name not in names_or_ids and i.id not in names_or_ids:
+ additional.append(i)
+ if additional:
+ msg = _('Additional images found in response')
+ raise exceptions.ClientException(500, msg)
+ return matches
+
def list(self):
"""
Get a detailed list of all images.
diff --git a/novaclient/v2/shell.py b/novaclient/v2/shell.py
index 2125ea99..0f8b5ce6 100644
--- a/novaclient/v2/shell.py
+++ b/novaclient/v2/shell.py
@@ -2570,6 +2570,14 @@ def _find_image(cs, image):
raise exceptions.CommandError(six.text_type(e))
+def _find_images(cs, images):
+ """Get images by name or ID."""
+ try:
+ return cs.glance.find_images(images)
+ except (exceptions.NotFound, exceptions.NoUniqueMatch) as e:
+ raise exceptions.CommandError(six.text_type(e))
+
+
def _find_flavor(cs, flavor):
"""Get a flavor by name, ID, or RAM size."""
try:
@@ -3518,6 +3526,21 @@ def _print_aggregate_details(cs, aggregate):
utils.print_list([aggregate], columns, formatters=formatters)
+@api_versions.wraps("2.81")
+@utils.arg(
+ 'aggregate', metavar='<aggregate>',
+ help=_('Name or ID of the aggregate.'))
+@utils.arg(
+ 'images', metavar='<image>', nargs='+',
+ help=_('Name or ID of image(s) to cache on the hosts within '
+ 'the aggregate.'))
+def do_aggregate_cache_images(cs, args):
+ """Request images be cached."""
+ aggregate = _find_aggregate(cs, args.aggregate)
+ images = _find_images(cs, args.images)
+ cs.aggregates.cache_images(aggregate, images)
+
+
@utils.arg('server', metavar='<server>', help=_('Name or ID of server.'))
@utils.arg(
'host', metavar='<host>', default=None, nargs='?',
diff --git a/releasenotes/notes/microversion-v2_81-3ddd8e2fc7e45030.yaml b/releasenotes/notes/microversion-v2_81-3ddd8e2fc7e45030.yaml
new file mode 100644
index 00000000..a51336d6
--- /dev/null
+++ b/releasenotes/notes/microversion-v2_81-3ddd8e2fc7e45030.yaml
@@ -0,0 +1,10 @@
+---
+features:
+ - |
+ Added support for `microversion 2.81`_ which adds image pre-caching support by
+ aggregate.
+
+ - The ``aggregate-cache-images`` command is added to the CLI
+ - The ``cache_images()`` method is added to the python API binding
+
+ .. _microversion 2.81: https://docs.openstack.org/nova/latest/reference/api-microversion-history.html#id73