Merge "Move print operations to shell_utils"
This commit is contained in:
Zuul
Gerrit Code Review
commit
6579899d3a
cinderclient
@ -15,6 +15,8 @@
|
||||
import sys
|
||||
import time
|
||||
|
||||
import prettytable
|
||||
|
||||
from cinderclient import exceptions
|
||||
from cinderclient import utils
|
||||
|
||||
@ -24,13 +26,109 @@ _quota_resources = ['volumes', 'snapshots', 'gigabytes',
|
||||
_quota_infos = ['Type', 'In_use', 'Reserved', 'Limit', 'Allocated']
|
||||
|
||||
|
||||
def _print(pt, order):
|
||||
print(pt.get_string(sortby=order))
|
||||
|
||||
|
||||
def _pretty_format_dict(data_dict):
|
||||
formatted_data = []
|
||||
|
||||
for k in sorted(data_dict):
|
||||
formatted_data.append("%s : %s" % (k, data_dict[k]))
|
||||
|
||||
return "\n".join(formatted_data)
|
||||
|
||||
|
||||
def print_list(objs, fields, exclude_unavailable=False, formatters=None,
|
||||
sortby_index=0):
|
||||
'''Prints a list of objects.
|
||||
|
||||
@param objs: Objects to print
|
||||
@param fields: Fields on each object to be printed
|
||||
@param exclude_unavailable: Boolean to decide if unavailable fields are
|
||||
removed
|
||||
@param formatters: Custom field formatters
|
||||
@param sortby_index: Results sorted against the key in the fields list at
|
||||
this index; if None then the object order is not
|
||||
altered
|
||||
'''
|
||||
formatters = formatters or {}
|
||||
mixed_case_fields = ['serverId']
|
||||
removed_fields = []
|
||||
rows = []
|
||||
|
||||
for o in objs:
|
||||
row = []
|
||||
for field in fields:
|
||||
if field in removed_fields:
|
||||
continue
|
||||
if field in formatters:
|
||||
row.append(formatters[field](o))
|
||||
else:
|
||||
if field in mixed_case_fields:
|
||||
field_name = field.replace(' ', '_')
|
||||
else:
|
||||
field_name = field.lower().replace(' ', '_')
|
||||
if isinstance(o, dict) and field in o:
|
||||
data = o[field]
|
||||
else:
|
||||
if not hasattr(o, field_name) and exclude_unavailable:
|
||||
removed_fields.append(field)
|
||||
continue
|
||||
else:
|
||||
data = getattr(o, field_name, '')
|
||||
if data is None:
|
||||
data = '-'
|
||||
if isinstance(data, str) and "\r" in data:
|
||||
data = data.replace("\r", " ")
|
||||
row.append(data)
|
||||
rows.append(row)
|
||||
|
||||
for f in removed_fields:
|
||||
fields.remove(f)
|
||||
|
||||
pt = prettytable.PrettyTable((f for f in fields), caching=False)
|
||||
pt.align = 'l'
|
||||
for row in rows:
|
||||
count = 0
|
||||
# Converts unicode values in dictionary to string
|
||||
for part in row:
|
||||
count = count + 1
|
||||
if isinstance(part, dict):
|
||||
row[count - 1] = part
|
||||
pt.add_row(row)
|
||||
|
||||
if sortby_index is None:
|
||||
order_by = None
|
||||
else:
|
||||
order_by = fields[sortby_index]
|
||||
_print(pt, order_by)
|
||||
|
||||
|
||||
def print_dict(d, property="Property", formatters=None):
|
||||
pt = prettytable.PrettyTable([property, 'Value'], caching=False)
|
||||
pt.align = 'l'
|
||||
formatters = formatters or {}
|
||||
|
||||
for r in d.items():
|
||||
r = list(r)
|
||||
|
||||
if r[0] in formatters:
|
||||
if isinstance(r[1], dict):
|
||||
r[1] = _pretty_format_dict(r[1])
|
||||
if isinstance(r[1], str) and "\r" in r[1]:
|
||||
r[1] = r[1].replace("\r", " ")
|
||||
pt.add_row(r)
|
||||
_print(pt, property)
|
||||
|
||||
|
||||
def print_volume_image(image_resp_tuple):
|
||||
# image_resp_tuple = tuple (response, body)
|
||||
image = image_resp_tuple[1]
|
||||
vt = image['os-volume_upload_image'].get('volume_type')
|
||||
if vt is not None:
|
||||
image['os-volume_upload_image']['volume_type'] = vt.get('name')
|
||||
utils.print_dict(image['os-volume_upload_image'])
|
||||
print_dict(image['os-volume_upload_image'])
|
||||
|
||||
|
||||
def poll_for_status(poll_fn, obj_id, action, final_ok_states,
|
||||
@ -120,7 +218,7 @@ def find_message(cs, message):
|
||||
|
||||
|
||||
def print_volume_snapshot(snapshot):
|
||||
utils.print_dict(snapshot._info)
|
||||
print_dict(snapshot._info)
|
||||
|
||||
|
||||
def translate_keys(collection, convert):
|
||||
@ -188,16 +286,16 @@ def extract_metadata(args, type='user_metadata'):
|
||||
|
||||
|
||||
def print_volume_type_list(vtypes):
|
||||
utils.print_list(vtypes, ['ID', 'Name', 'Description', 'Is_Public'])
|
||||
print_list(vtypes, ['ID', 'Name', 'Description', 'Is_Public'])
|
||||
|
||||
|
||||
def print_group_type_list(gtypes):
|
||||
utils.print_list(gtypes, ['ID', 'Name', 'Description'])
|
||||
print_list(gtypes, ['ID', 'Name', 'Description'])
|
||||
|
||||
|
||||
def print_resource_filter_list(filters):
|
||||
formatter = {'Filters': lambda resource: ', '.join(resource.filters)}
|
||||
utils.print_list(filters, ['Resource', 'Filters'], formatters=formatter)
|
||||
print_list(filters, ['Resource', 'Filters'], formatters=formatter)
|
||||
|
||||
|
||||
def quota_show(quotas):
|
||||
@ -211,7 +309,7 @@ def quota_show(quotas):
|
||||
if not good_name:
|
||||
continue
|
||||
quota_dict[resource] = getattr(quotas, resource, None)
|
||||
utils.print_dict(quota_dict)
|
||||
print_dict(quota_dict)
|
||||
|
||||
|
||||
def quota_usage_show(quotas):
|
||||
@ -228,7 +326,7 @@ def quota_usage_show(quotas):
|
||||
quota_info['Type'] = resource
|
||||
quota_info = dict((k.capitalize(), v) for k, v in quota_info.items())
|
||||
quota_list.append(quota_info)
|
||||
utils.print_list(quota_list, _quota_infos)
|
||||
print_list(quota_list, _quota_infos)
|
||||
|
||||
|
||||
def quota_update(manager, identifier, args):
|
||||
@ -266,26 +364,26 @@ def print_volume_encryption_type_list(encryption_types):
|
||||
|
||||
:param encryption_types: a list of :class: VolumeEncryptionType instances
|
||||
"""
|
||||
utils.print_list(encryption_types, ['Volume Type ID', 'Provider',
|
||||
'Cipher', 'Key Size',
|
||||
'Control Location'])
|
||||
print_list(encryption_types, ['Volume Type ID', 'Provider',
|
||||
'Cipher', 'Key Size',
|
||||
'Control Location'])
|
||||
|
||||
|
||||
def print_qos_specs(qos_specs):
|
||||
# formatters defines field to be converted from unicode to string
|
||||
utils.print_dict(qos_specs._info, formatters=['specs'])
|
||||
print_dict(qos_specs._info, formatters=['specs'])
|
||||
|
||||
|
||||
def print_qos_specs_list(q_specs):
|
||||
utils.print_list(q_specs, ['ID', 'Name', 'Consumer', 'specs'])
|
||||
print_list(q_specs, ['ID', 'Name', 'Consumer', 'specs'])
|
||||
|
||||
|
||||
def print_qos_specs_and_associations_list(q_specs):
|
||||
utils.print_list(q_specs, ['ID', 'Name', 'Consumer', 'specs'])
|
||||
print_list(q_specs, ['ID', 'Name', 'Consumer', 'specs'])
|
||||
|
||||
|
||||
def print_associations_list(associations):
|
||||
utils.print_list(associations, ['Association_Type', 'Name', 'ID'])
|
||||
print_list(associations, ['Association_Type', 'Name', 'ID'])
|
||||
|
||||
|
||||
def _poll_for_status(poll_fn, obj_id, info, action, final_ok_states,
|
||||
@ -305,7 +403,7 @@ def _poll_for_status(poll_fn, obj_id, info, action, final_ok_states,
|
||||
if status in final_ok_states:
|
||||
break
|
||||
elif status == "error":
|
||||
utils.print_dict(info)
|
||||
print_dict(info)
|
||||
if global_request_id:
|
||||
search_opts = {
|
||||
'request_id': global_request_id
|
||||
@ -317,5 +415,5 @@ def _poll_for_status(poll_fn, obj_id, info, action, final_ok_states,
|
||||
fault_msg = "Unknown error. Operation failed."
|
||||
raise exceptions.ResourceInErrorState(obj, fault_msg)
|
||||
elif time_elapsed == timeout_period:
|
||||
utils.print_dict(info)
|
||||
print_dict(info)
|
||||
raise exceptions.TimeoutException(obj, action)
|
||||
|
||||
@ -554,7 +554,7 @@ class TestLoadVersionedActions(utils.TestCase):
|
||||
|
||||
class ShellUtilsTest(utils.TestCase):
|
||||
|
||||
@mock.patch.object(cinderclient.utils, 'print_dict')
|
||||
@mock.patch.object(cinderclient.shell_utils, 'print_dict')
|
||||
def test_print_volume_image(self, mock_print_dict):
|
||||
response = {'os-volume_upload_image': {'name': 'myimg1'}}
|
||||
image_resp_tuple = (202, response)
|
||||
|
||||
@ -220,7 +220,7 @@ class PrintListTestCase(test_utils.TestCase):
|
||||
Row = collections.namedtuple('Row', ['a', 'b'])
|
||||
to_print = [Row(a=3, b=4), Row(a=1, b=2)]
|
||||
with CaptureStdout() as cso:
|
||||
utils.print_list(to_print, ['a', 'b'])
|
||||
shell_utils.print_list(to_print, ['a', 'b'])
|
||||
# Output should be sorted by the first key (a)
|
||||
self.assertEqual("""\
|
||||
+---+---+
|
||||
@ -235,7 +235,7 @@ class PrintListTestCase(test_utils.TestCase):
|
||||
Row = collections.namedtuple('Row', ['a', 'b'])
|
||||
to_print = [Row(a=3, b=None), Row(a=1, b=2)]
|
||||
with CaptureStdout() as cso:
|
||||
utils.print_list(to_print, ['a', 'b'])
|
||||
shell_utils.print_list(to_print, ['a', 'b'])
|
||||
# Output should be sorted by the first key (a)
|
||||
self.assertEqual("""\
|
||||
+---+---+
|
||||
@ -250,7 +250,7 @@ class PrintListTestCase(test_utils.TestCase):
|
||||
Row = collections.namedtuple('Row', ['a', 'b'])
|
||||
to_print = [Row(a=4, b=3), Row(a=2, b=1)]
|
||||
with CaptureStdout() as cso:
|
||||
utils.print_list(to_print, ['a', 'b'], sortby_index=1)
|
||||
shell_utils.print_list(to_print, ['a', 'b'], sortby_index=1)
|
||||
# Output should be sorted by the second key (b)
|
||||
self.assertEqual("""\
|
||||
+---+---+
|
||||
@ -265,7 +265,7 @@ class PrintListTestCase(test_utils.TestCase):
|
||||
Row = collections.namedtuple('Row', ['a', 'b'])
|
||||
to_print = [Row(a=3, b=4), Row(a=1, b=2)]
|
||||
with CaptureStdout() as cso:
|
||||
utils.print_list(to_print, ['a', 'b'], sortby_index=None)
|
||||
shell_utils.print_list(to_print, ['a', 'b'], sortby_index=None)
|
||||
# Output should be in the order given
|
||||
self.assertEqual("""\
|
||||
+---+---+
|
||||
@ -283,7 +283,7 @@ class PrintListTestCase(test_utils.TestCase):
|
||||
for row in [Row(a=1, b=2), Row(a=3, b=4)]:
|
||||
yield row
|
||||
with CaptureStdout() as cso:
|
||||
utils.print_list(gen_rows(), ['a', 'b'])
|
||||
shell_utils.print_list(gen_rows(), ['a', 'b'])
|
||||
self.assertEqual("""\
|
||||
+---+---+
|
||||
| a | b |
|
||||
@ -297,7 +297,7 @@ class PrintListTestCase(test_utils.TestCase):
|
||||
Row = collections.namedtuple('Row', ['a', 'b'])
|
||||
to_print = [Row(a=3, b='a\r'), Row(a=1, b='c\rd')]
|
||||
with CaptureStdout() as cso:
|
||||
utils.print_list(to_print, ['a', 'b'])
|
||||
shell_utils.print_list(to_print, ['a', 'b'])
|
||||
# Output should be sorted by the first key (a)
|
||||
self.assertEqual("""\
|
||||
+---+-----+
|
||||
@ -314,13 +314,13 @@ class PrintDictTestCase(test_utils.TestCase):
|
||||
def test__pretty_format_dict(self):
|
||||
content = {'key1': 'value1', 'key2': 'value2'}
|
||||
expected = "key1 : value1\nkey2 : value2"
|
||||
result = utils._pretty_format_dict(content)
|
||||
result = shell_utils._pretty_format_dict(content)
|
||||
self.assertEqual(expected, result)
|
||||
|
||||
def test_print_dict_with_return(self):
|
||||
d = {'a': 'A', 'b': 'B', 'c': 'C', 'd': 'test\rcarriage\n\rreturn'}
|
||||
with CaptureStdout() as cso:
|
||||
utils.print_dict(d)
|
||||
shell_utils.print_dict(d)
|
||||
self.assertEqual("""\
|
||||
+----------+---------------+
|
||||
| Property | Value |
|
||||
@ -337,7 +337,7 @@ class PrintDictTestCase(test_utils.TestCase):
|
||||
content = {'a': 'A', 'b': 'B', 'f_key':
|
||||
{'key1': 'value1', 'key2': 'value2'}}
|
||||
with CaptureStdout() as cso:
|
||||
utils.print_dict(content, formatters='f_key')
|
||||
shell_utils.print_dict(content, formatters='f_key')
|
||||
self.assertEqual("""\
|
||||
+----------+---------------+
|
||||
| Property | Value |
|
||||
|
||||
@ -352,7 +352,7 @@ class ShellTest(utils.TestCase):
|
||||
self.run_command(command)
|
||||
self.assert_called('GET', '/volumes/detail?group_id=fake_id')
|
||||
|
||||
@mock.patch("cinderclient.utils.print_list")
|
||||
@mock.patch("cinderclient.shell_utils.print_list")
|
||||
def test_list_duplicate_fields(self, mock_print):
|
||||
self.run_command('list --field Status,id,Size,status')
|
||||
self.assert_called('GET', '/volumes/detail')
|
||||
@ -528,7 +528,7 @@ class ShellTest(utils.TestCase):
|
||||
self.run_command(command)
|
||||
self.assert_called('GET', '/attachments%s' % expected)
|
||||
|
||||
@mock.patch('cinderclient.utils.print_list')
|
||||
@mock.patch('cinderclient.shell_utils.print_list')
|
||||
@mock.patch.object(cinderclient.v3.attachments.VolumeAttachmentManager,
|
||||
'list')
|
||||
def test_attachment_list_setattr(self, mock_list, mock_print):
|
||||
@ -1285,7 +1285,7 @@ class ShellTest(utils.TestCase):
|
||||
get_levels_mock.assert_not_called()
|
||||
|
||||
@mock.patch('cinderclient.v3.services.ServiceManager.get_log_levels')
|
||||
@mock.patch('cinderclient.utils.print_list')
|
||||
@mock.patch('cinderclient.shell_utils.print_list')
|
||||
def test_service_get_log_no_params(self, print_mock, get_levels_mock):
|
||||
self.run_command('--os-volume-api-version 3.32 service-get-log')
|
||||
get_levels_mock.assert_called_once_with('', '', '')
|
||||
@ -1296,7 +1296,7 @@ class ShellTest(utils.TestCase):
|
||||
@ddt.data('*', 'cinder-api', 'cinder-volume', 'cinder-scheduler',
|
||||
'cinder-backup')
|
||||
@mock.patch('cinderclient.v3.services.ServiceManager.get_log_levels')
|
||||
@mock.patch('cinderclient.utils.print_list')
|
||||
@mock.patch('cinderclient.shell_utils.print_list')
|
||||
def test_service_get_log(self, binary, print_mock, get_levels_mock):
|
||||
server = 'host1'
|
||||
prefix = 'sqlalchemy'
|
||||
@ -1454,7 +1454,7 @@ class ShellTest(utils.TestCase):
|
||||
'availability_zone': 'AZ2'}}
|
||||
self.assert_called('POST', '/backups', body=expected)
|
||||
|
||||
@mock.patch("cinderclient.utils.print_list")
|
||||
@mock.patch("cinderclient.shell_utils.print_list")
|
||||
def test_snapshot_list(self, mock_print_list):
|
||||
"""Ensure we always present all existing fields when listing snaps."""
|
||||
self.run_command('--os-volume-api-version 3.65 snapshot-list')
|
||||
@ -1923,7 +1923,7 @@ class ShellTest(utils.TestCase):
|
||||
},
|
||||
)
|
||||
@ddt.unpack
|
||||
@mock.patch('cinderclient.utils.print_dict')
|
||||
@mock.patch('cinderclient.shell_utils.print_dict')
|
||||
@mock.patch('cinderclient.tests.unit.v3.fakes_base._stub_restore')
|
||||
def test_do_backup_restore(self,
|
||||
mock_stub_restore,
|
||||
|
||||
@ -18,7 +18,6 @@ import os
|
||||
from urllib import parse
|
||||
import uuid
|
||||
|
||||
import prettytable
|
||||
import stevedore
|
||||
|
||||
from cinderclient import exceptions
|
||||
@ -106,76 +105,6 @@ def isunauthenticated(f):
|
||||
return getattr(f, 'unauthenticated', False)
|
||||
|
||||
|
||||
def _print(pt, order):
|
||||
print(pt.get_string(sortby=order))
|
||||
|
||||
|
||||
def print_list(objs, fields, exclude_unavailable=False, formatters=None,
|
||||
sortby_index=0):
|
||||
'''Prints a list of objects.
|
||||
|
||||
@param objs: Objects to print
|
||||
@param fields: Fields on each object to be printed
|
||||
@param exclude_unavailable: Boolean to decide if unavailable fields are
|
||||
removed
|
||||
@param formatters: Custom field formatters
|
||||
@param sortby_index: Results sorted against the key in the fields list at
|
||||
this index; if None then the object order is not
|
||||
altered
|
||||
'''
|
||||
formatters = formatters or {}
|
||||
mixed_case_fields = ['serverId']
|
||||
removed_fields = []
|
||||
rows = []
|
||||
|
||||
for o in objs:
|
||||
row = []
|
||||
for field in fields:
|
||||
if field in removed_fields:
|
||||
continue
|
||||
if field in formatters:
|
||||
row.append(formatters[field](o))
|
||||
else:
|
||||
if field in mixed_case_fields:
|
||||
field_name = field.replace(' ', '_')
|
||||
else:
|
||||
field_name = field.lower().replace(' ', '_')
|
||||
if isinstance(o, dict) and field in o:
|
||||
data = o[field]
|
||||
else:
|
||||
if not hasattr(o, field_name) and exclude_unavailable:
|
||||
removed_fields.append(field)
|
||||
continue
|
||||
else:
|
||||
data = getattr(o, field_name, '')
|
||||
if data is None:
|
||||
data = '-'
|
||||
if isinstance(data, str) and "\r" in data:
|
||||
data = data.replace("\r", " ")
|
||||
row.append(data)
|
||||
rows.append(row)
|
||||
|
||||
for f in removed_fields:
|
||||
fields.remove(f)
|
||||
|
||||
pt = prettytable.PrettyTable((f for f in fields), caching=False)
|
||||
pt.align = 'l'
|
||||
for row in rows:
|
||||
count = 0
|
||||
# Converts unicode values in dictionary to string
|
||||
for part in row:
|
||||
count = count + 1
|
||||
if isinstance(part, dict):
|
||||
row[count - 1] = part
|
||||
pt.add_row(row)
|
||||
|
||||
if sortby_index is None:
|
||||
order_by = None
|
||||
else:
|
||||
order_by = fields[sortby_index]
|
||||
_print(pt, order_by)
|
||||
|
||||
|
||||
def build_query_param(params, sort=False):
|
||||
"""parse list to url query parameters"""
|
||||
|
||||
@ -206,32 +135,6 @@ def build_query_param(params, sort=False):
|
||||
return query_string
|
||||
|
||||
|
||||
def _pretty_format_dict(data_dict):
|
||||
formatted_data = []
|
||||
|
||||
for k in sorted(data_dict):
|
||||
formatted_data.append("%s : %s" % (k, data_dict[k]))
|
||||
|
||||
return "\n".join(formatted_data)
|
||||
|
||||
|
||||
def print_dict(d, property="Property", formatters=None):
|
||||
pt = prettytable.PrettyTable([property, 'Value'], caching=False)
|
||||
pt.align = 'l'
|
||||
formatters = formatters or {}
|
||||
|
||||
for r in d.items():
|
||||
r = list(r)
|
||||
|
||||
if r[0] in formatters:
|
||||
if isinstance(r[1], dict):
|
||||
r[1] = _pretty_format_dict(r[1])
|
||||
if isinstance(r[1], str) and "\r" in r[1]:
|
||||
r[1] = r[1].replace("\r", " ")
|
||||
pt.add_row(r)
|
||||
_print(pt, property)
|
||||
|
||||
|
||||
def find_resource(manager, name_or_id, **kwargs):
|
||||
"""Helper for the _find_* methods."""
|
||||
is_group = kwargs.pop('is_group', False)
|
||||
|
||||
@ -14,7 +14,7 @@
|
||||
# under the License.
|
||||
|
||||
from cinderclient import base
|
||||
from cinderclient import utils
|
||||
from cinderclient import shell_utils
|
||||
|
||||
|
||||
class ListExtResource(base.Resource):
|
||||
@ -41,4 +41,4 @@ def do_list_extensions(client, _args):
|
||||
"""Lists all available os-api extensions."""
|
||||
extensions = client.list_extensions.show_all()
|
||||
fields = ["Name", "Summary", "Alias", "Updated"]
|
||||
utils.print_list(extensions, fields)
|
||||
shell_utils.print_list(extensions, fields)
|
||||
|
||||
@ -197,7 +197,7 @@ def do_backup_list(cs, args):
|
||||
sortby_index = None
|
||||
else:
|
||||
sortby_index = 0
|
||||
utils.print_list(backups, columns, sortby_index=sortby_index)
|
||||
shell_utils.print_list(backups, columns, sortby_index=sortby_index)
|
||||
if show_count:
|
||||
print("Backup in total: %s" % total_count)
|
||||
|
||||
@ -282,7 +282,7 @@ def do_backup_restore(cs, args):
|
||||
info.update(restore._info)
|
||||
info.pop('links', None)
|
||||
|
||||
utils.print_dict(info)
|
||||
shell_utils.print_dict(info)
|
||||
|
||||
|
||||
@utils.arg('--detail',
|
||||
@ -316,7 +316,7 @@ def do_get_pools(cs, args):
|
||||
backend['name'] = info['name']
|
||||
if args.detail:
|
||||
backend.update(info['capabilities'])
|
||||
utils.print_dict(backend)
|
||||
shell_utils.print_dict(backend)
|
||||
AppendFilters.filters = []
|
||||
|
||||
|
||||
@ -518,7 +518,7 @@ def do_list(cs, args):
|
||||
sortby_index = None
|
||||
else:
|
||||
sortby_index = 0
|
||||
utils.print_list(volumes, key_list, exclude_unavailable=True,
|
||||
shell_utils.print_list(volumes, key_list, exclude_unavailable=True,
|
||||
sortby_index=sortby_index)
|
||||
if show_count:
|
||||
print("Volume in total: %s" % total_count)
|
||||
@ -747,7 +747,7 @@ def do_create(cs, args):
|
||||
volume = cs.volumes.get(volume.id)
|
||||
info.update(volume._info)
|
||||
|
||||
utils.print_dict(info)
|
||||
shell_utils.print_dict(info)
|
||||
|
||||
with cs.volumes.completion_cache('uuid',
|
||||
cinderclient.v3.volumes.Volume,
|
||||
@ -812,7 +812,7 @@ def do_summary(cs, args):
|
||||
if cs.api_version >= api_versions.APIVersion("3.36"):
|
||||
formatters.append('metadata')
|
||||
|
||||
utils.print_dict(info['volume-summary'], formatters=formatters)
|
||||
shell_utils.print_dict(info['volume-summary'], formatters=formatters)
|
||||
|
||||
|
||||
@api_versions.wraps('3.11')
|
||||
@ -853,7 +853,7 @@ def do_group_type_show(cs, args):
|
||||
info.update(gtype._info)
|
||||
|
||||
info.pop('links', None)
|
||||
utils.print_dict(info, formatters=['group_specs'])
|
||||
shell_utils.print_dict(info, formatters=['group_specs'])
|
||||
|
||||
|
||||
@api_versions.wraps('3.11')
|
||||
@ -881,7 +881,7 @@ def do_group_type_update(cs, args):
|
||||
def do_group_specs_list(cs, args):
|
||||
"""Lists current group types and specs."""
|
||||
gtypes = cs.group_types.list()
|
||||
utils.print_list(gtypes, ['ID', 'Name', 'group_specs'])
|
||||
shell_utils.print_list(gtypes, ['ID', 'Name', 'group_specs'])
|
||||
|
||||
|
||||
@api_versions.wraps('3.11')
|
||||
@ -1170,7 +1170,7 @@ def do_cluster_list(cs, args):
|
||||
if args.detailed:
|
||||
columns.extend(('Num Hosts', 'Num Down Hosts', 'Last Heartbeat',
|
||||
'Disabled Reason', 'Created At', 'Updated at'))
|
||||
utils.print_list(clusters, columns)
|
||||
shell_utils.print_list(clusters, columns)
|
||||
|
||||
|
||||
@api_versions.wraps('3.7')
|
||||
@ -1181,7 +1181,7 @@ def do_cluster_list(cs, args):
|
||||
def do_cluster_show(cs, args):
|
||||
"""Show detailed information on a clustered service."""
|
||||
cluster = cs.clusters.show(args.name, args.binary)
|
||||
utils.print_dict(cluster.to_dict())
|
||||
shell_utils.print_dict(cluster.to_dict())
|
||||
|
||||
|
||||
@api_versions.wraps('3.7')
|
||||
@ -1192,7 +1192,7 @@ def do_cluster_show(cs, args):
|
||||
def do_cluster_enable(cs, args):
|
||||
"""Enables clustered services."""
|
||||
cluster = cs.clusters.update(args.name, args.binary, disabled=False)
|
||||
utils.print_dict(cluster.to_dict())
|
||||
shell_utils.print_dict(cluster.to_dict())
|
||||
|
||||
|
||||
@api_versions.wraps('3.7')
|
||||
@ -1206,7 +1206,7 @@ def do_cluster_disable(cs, args):
|
||||
"""Disables clustered services."""
|
||||
cluster = cs.clusters.update(args.name, args.binary, disabled=True,
|
||||
disabled_reason=args.reason)
|
||||
utils.print_dict(cluster.to_dict())
|
||||
shell_utils.print_dict(cluster.to_dict())
|
||||
|
||||
|
||||
@api_versions.wraps('3.24')
|
||||
@ -1251,12 +1251,12 @@ def do_work_cleanup(cs, args):
|
||||
|
||||
if cleaning:
|
||||
print('Following services will be cleaned:')
|
||||
utils.print_list(cleaning, columns)
|
||||
shell_utils.print_list(cleaning, columns)
|
||||
|
||||
if unavailable:
|
||||
print('There are no alternative nodes to do cleanup for the following '
|
||||
'services:')
|
||||
utils.print_list(unavailable, columns)
|
||||
shell_utils.print_list(unavailable, columns)
|
||||
|
||||
if not (cleaning or unavailable):
|
||||
print('No cleanable services matched cleanup criteria.')
|
||||
@ -1337,7 +1337,7 @@ def do_manage(cs, args):
|
||||
volume = cs.volumes.get(volume.id)
|
||||
info.update(volume._info)
|
||||
info.pop('links', None)
|
||||
utils.print_dict(info)
|
||||
shell_utils.print_dict(info)
|
||||
|
||||
|
||||
@api_versions.wraps('3.8')
|
||||
@ -1394,7 +1394,7 @@ def do_manageable_list(cs, args):
|
||||
columns = ['reference', 'size', 'safe_to_manage']
|
||||
if detailed:
|
||||
columns.extend(['reason_not_safe', 'cinder_id', 'extra_info'])
|
||||
utils.print_list(volumes, columns, sortby_index=None)
|
||||
shell_utils.print_list(volumes, columns, sortby_index=None)
|
||||
|
||||
|
||||
@api_versions.wraps('3.13')
|
||||
@ -1427,7 +1427,7 @@ def do_group_list(cs, args):
|
||||
groups = cs.groups.list(search_opts=search_opts)
|
||||
|
||||
columns = ['ID', 'Status', 'Name']
|
||||
utils.print_list(groups, columns)
|
||||
shell_utils.print_list(groups, columns)
|
||||
|
||||
with cs.groups.completion_cache(
|
||||
'uuid',
|
||||
@ -1469,7 +1469,7 @@ def do_group_show(cs, args):
|
||||
info.update(group._info)
|
||||
|
||||
info.pop('links', None)
|
||||
utils.print_dict(info)
|
||||
shell_utils.print_dict(info)
|
||||
|
||||
|
||||
@api_versions.wraps('3.13')
|
||||
@ -1505,7 +1505,7 @@ def do_group_create(cs, args):
|
||||
info.update(group._info)
|
||||
|
||||
info.pop('links', None)
|
||||
utils.print_dict(info)
|
||||
shell_utils.print_dict(info)
|
||||
|
||||
with cs.groups.completion_cache('uuid',
|
||||
cinderclient.v3.groups.Group,
|
||||
@ -1556,7 +1556,7 @@ def do_group_create_from_src(cs, args):
|
||||
args.description)
|
||||
|
||||
info.pop('links', None)
|
||||
utils.print_dict(info)
|
||||
shell_utils.print_dict(info)
|
||||
|
||||
|
||||
@api_versions.wraps('3.13')
|
||||
@ -1696,7 +1696,8 @@ def do_group_list_replication_targets(cs, args):
|
||||
cs, args.group).list_replication_targets()
|
||||
rep_targets = replication_targets.get('replication_targets')
|
||||
if rep_targets and len(rep_targets) > 0:
|
||||
utils.print_list(rep_targets, [key for key in rep_targets[0].keys()])
|
||||
shell_utils.print_list(rep_targets,
|
||||
[key for key in rep_targets[0].keys()])
|
||||
|
||||
|
||||
@api_versions.wraps('3.14')
|
||||
@ -1743,7 +1744,7 @@ def do_group_snapshot_list(cs, args):
|
||||
group_snapshots = cs.group_snapshots.list(search_opts=search_opts)
|
||||
|
||||
columns = ['ID', 'Status', 'Name']
|
||||
utils.print_list(group_snapshots, columns)
|
||||
shell_utils.print_list(group_snapshots, columns)
|
||||
AppendFilters.filters = []
|
||||
|
||||
|
||||
@ -1758,7 +1759,7 @@ def do_group_snapshot_show(cs, args):
|
||||
info.update(group_snapshot._info)
|
||||
|
||||
info.pop('links', None)
|
||||
utils.print_dict(info)
|
||||
shell_utils.print_dict(info)
|
||||
|
||||
|
||||
@api_versions.wraps('3.14')
|
||||
@ -1786,7 +1787,7 @@ def do_group_snapshot_create(cs, args):
|
||||
info.update(group_snapshot._info)
|
||||
|
||||
info.pop('links', None)
|
||||
utils.print_dict(info)
|
||||
shell_utils.print_dict(info)
|
||||
|
||||
|
||||
@api_versions.wraps('3.14')
|
||||
@ -1841,7 +1842,7 @@ def do_service_list(cs, args):
|
||||
columns.append("Disabled Reason")
|
||||
if cs.api_version.matches('3.49'):
|
||||
columns.extend(["Backend State"])
|
||||
utils.print_list(result, columns)
|
||||
shell_utils.print_list(result, columns)
|
||||
|
||||
|
||||
@api_versions.wraps('3.8')
|
||||
@ -1900,7 +1901,7 @@ def do_snapshot_manageable_list(cs, args):
|
||||
columns = ['reference', 'size', 'safe_to_manage', 'source_reference']
|
||||
if detailed:
|
||||
columns.extend(['reason_not_safe', 'cinder_id', 'extra_info'])
|
||||
utils.print_list(snapshots, columns, sortby_index=None)
|
||||
shell_utils.print_list(snapshots, columns, sortby_index=None)
|
||||
|
||||
|
||||
@api_versions.wraps("3.0")
|
||||
@ -1908,7 +1909,7 @@ def do_api_version(cs, args):
|
||||
"""Display the server API version information."""
|
||||
columns = ['ID', 'Status', 'Version', 'Min_version']
|
||||
response = cs.services.server_api_version()
|
||||
utils.print_list(response, columns)
|
||||
shell_utils.print_list(response, columns)
|
||||
|
||||
|
||||
@api_versions.wraps("3.40")
|
||||
@ -2010,7 +2011,7 @@ def do_message_list(cs, args):
|
||||
sortby_index = None
|
||||
else:
|
||||
sortby_index = 0
|
||||
utils.print_list(messages, columns, sortby_index=sortby_index)
|
||||
shell_utils.print_list(messages, columns, sortby_index=sortby_index)
|
||||
AppendFilters.filters = []
|
||||
|
||||
|
||||
@ -2024,7 +2025,7 @@ def do_message_show(cs, args):
|
||||
message = shell_utils.find_message(cs, args.message)
|
||||
info.update(message._info)
|
||||
info.pop('links', None)
|
||||
utils.print_dict(info)
|
||||
shell_utils.print_dict(info)
|
||||
|
||||
|
||||
@api_versions.wraps("3.3")
|
||||
@ -2179,11 +2180,11 @@ def do_snapshot_list(cs, args):
|
||||
# It's the server's responsibility to return the appropriate fields for the
|
||||
# requested microversion, we present all known fields and skip those that
|
||||
# are missing.
|
||||
utils.print_list(snapshots,
|
||||
['ID', 'Volume ID', 'Status', 'Name', 'Size',
|
||||
'Consumes Quota', 'User ID'],
|
||||
exclude_unavailable=True,
|
||||
sortby_index=sortby_index)
|
||||
shell_utils.print_list(snapshots,
|
||||
['ID', 'Volume ID', 'Status', 'Name', 'Size',
|
||||
'Consumes Quota', 'User ID'],
|
||||
exclude_unavailable=True,
|
||||
sortby_index=sortby_index)
|
||||
if show_count:
|
||||
print("Snapshot in total: %s" % total_count)
|
||||
|
||||
@ -2411,7 +2412,7 @@ def do_attachment_list(cs, args):
|
||||
sortby_index = None
|
||||
else:
|
||||
sortby_index = 0
|
||||
utils.print_list(attachments, columns, sortby_index=sortby_index)
|
||||
shell_utils.print_list(attachments, columns, sortby_index=sortby_index)
|
||||
AppendFilters.filters = []
|
||||
|
||||
|
||||
@ -2424,13 +2425,13 @@ def do_attachment_show(cs, args):
|
||||
attachment = cs.attachments.show(args.attachment)
|
||||
attachment_dict = attachment.to_dict()
|
||||
connection_dict = attachment_dict.pop('connection_info', {})
|
||||
utils.print_dict(attachment_dict)
|
||||
shell_utils.print_dict(attachment_dict)
|
||||
|
||||
# TODO(jdg): Need to add checks here like admin/policy for displaying the
|
||||
# connection_info, this is still experimental so we'll leave it enabled for
|
||||
# now
|
||||
if connection_dict:
|
||||
utils.print_dict(connection_dict)
|
||||
shell_utils.print_dict(connection_dict)
|
||||
|
||||
|
||||
@api_versions.wraps('3.27')
|
||||
@ -2503,9 +2504,9 @@ def do_attachment_create(cs, args):
|
||||
mode)
|
||||
|
||||
connector_dict = attachment.pop('connection_info', None)
|
||||
utils.print_dict(attachment)
|
||||
shell_utils.print_dict(attachment)
|
||||
if connector_dict:
|
||||
utils.print_dict(connector_dict)
|
||||
shell_utils.print_dict(connector_dict)
|
||||
|
||||
|
||||
@api_versions.wraps('3.27')
|
||||
@ -2557,9 +2558,9 @@ def do_attachment_update(cs, args):
|
||||
connector)
|
||||
attachment_dict = attachment.to_dict()
|
||||
connector_dict = attachment_dict.pop('connection_info', None)
|
||||
utils.print_dict(attachment_dict)
|
||||
shell_utils.print_dict(attachment_dict)
|
||||
if connector_dict:
|
||||
utils.print_dict(connector_dict)
|
||||
shell_utils.print_dict(connector_dict)
|
||||
|
||||
|
||||
@api_versions.wraps('3.27')
|
||||
@ -2598,7 +2599,7 @@ def do_version_list(cs, args):
|
||||
{'v': api_versions.MAX_VERSION})
|
||||
|
||||
print("\nServer supported API versions:")
|
||||
utils.print_list(result, columns)
|
||||
shell_utils.print_list(result, columns)
|
||||
|
||||
|
||||
@api_versions.wraps('3.32')
|
||||
@ -2641,7 +2642,7 @@ def do_service_get_log(cs, args):
|
||||
log_levels = cs.services.get_log_levels(args.binary, args.server,
|
||||
args.prefix)
|
||||
columns = ('Binary', 'Host', 'Prefix', 'Level')
|
||||
utils.print_list(log_levels, columns)
|
||||
shell_utils.print_list(log_levels, columns)
|
||||
|
||||
|
||||
@utils.arg('volume', metavar='<volume>',
|
||||
@ -2718,7 +2719,7 @@ def do_backup_create(cs, args):
|
||||
if 'links' in info:
|
||||
info.pop('links')
|
||||
|
||||
utils.print_dict(info)
|
||||
shell_utils.print_dict(info)
|
||||
|
||||
with cs.backups.completion_cache(
|
||||
'uuid',
|
||||
@ -2759,7 +2760,7 @@ def do_transfer_create(cs, args):
|
||||
info.update(transfer._info)
|
||||
|
||||
info.pop('links', None)
|
||||
utils.print_dict(info)
|
||||
shell_utils.print_dict(info)
|
||||
|
||||
|
||||
@utils.arg('--all-tenants',
|
||||
@ -2807,7 +2808,7 @@ def do_transfer_list(cs, args):
|
||||
|
||||
transfers = cs.transfers.list(search_opts=search_opts, sort=sort)
|
||||
columns = ['ID', 'Volume ID', 'Name']
|
||||
utils.print_list(transfers, columns)
|
||||
shell_utils.print_list(transfers, columns)
|
||||
AppendFilters.filters = []
|
||||
|
||||
|
||||
@ -2824,7 +2825,7 @@ def do_default_type_set(cs, args):
|
||||
project = args.project
|
||||
|
||||
default_type = cs.default_types.create(volume_type, project)
|
||||
utils.print_dict(default_type._info)
|
||||
shell_utils.print_dict(default_type._info)
|
||||
|
||||
|
||||
@api_versions.wraps('3.62')
|
||||
@ -2839,9 +2840,9 @@ def do_default_type_list(cs, args):
|
||||
default_types = cs.default_types.list(project_id)
|
||||
columns = ['Volume Type ID', 'Project ID']
|
||||
if project_id:
|
||||
utils.print_dict(default_types._info)
|
||||
shell_utils.print_dict(default_types._info)
|
||||
else:
|
||||
utils.print_list(default_types, columns)
|
||||
shell_utils.print_list(default_types, columns)
|
||||
|
||||
|
||||
@api_versions.wraps('3.62')
|
||||
|
||||
@ -163,7 +163,7 @@ def do_list(cs, args):
|
||||
sortby_index = None
|
||||
else:
|
||||
sortby_index = 0
|
||||
utils.print_list(volumes, key_list, exclude_unavailable=True,
|
||||
shell_utils.print_list(volumes, key_list, exclude_unavailable=True,
|
||||
sortby_index=sortby_index)
|
||||
|
||||
|
||||
@ -181,9 +181,9 @@ def do_show(cs, args):
|
||||
|
||||
info.pop('links', None)
|
||||
info = _translate_attachments(info)
|
||||
utils.print_dict(info,
|
||||
formatters=['metadata', 'volume_image_metadata',
|
||||
'attachment_ids', 'attached_servers'])
|
||||
shell_utils.print_dict(info,
|
||||
formatters=['metadata', 'volume_image_metadata',
|
||||
'attachment_ids', 'attached_servers'])
|
||||
|
||||
|
||||
class CheckSizeArgForCreate(argparse.Action):
|
||||
@ -325,7 +325,7 @@ def do_create(cs, args):
|
||||
|
||||
info.pop('links', None)
|
||||
info = _translate_attachments(info)
|
||||
utils.print_dict(info)
|
||||
shell_utils.print_dict(info)
|
||||
|
||||
|
||||
@utils.arg('--cascade',
|
||||
@ -581,9 +581,9 @@ def do_snapshot_list(cs, args):
|
||||
else:
|
||||
sortby_index = 0
|
||||
|
||||
utils.print_list(snapshots,
|
||||
['ID', 'Volume ID', 'Status', 'Name', 'Size'],
|
||||
sortby_index=sortby_index)
|
||||
shell_utils.print_list(snapshots,
|
||||
['ID', 'Volume ID', 'Status', 'Name', 'Size'],
|
||||
sortby_index=sortby_index)
|
||||
|
||||
|
||||
@utils.arg('snapshot',
|
||||
@ -714,7 +714,7 @@ def do_type_show(cs, args):
|
||||
info.update(vtype._info)
|
||||
|
||||
info.pop('links', None)
|
||||
utils.print_dict(info, formatters=['extra_specs'])
|
||||
shell_utils.print_dict(info, formatters=['extra_specs'])
|
||||
|
||||
|
||||
@utils.arg('id',
|
||||
@ -746,7 +746,7 @@ def do_type_update(cs, args):
|
||||
def do_extra_specs_list(cs, args):
|
||||
"""Lists current volume types and extra specs."""
|
||||
vtypes = cs.volume_types.list()
|
||||
utils.print_list(vtypes, ['ID', 'Name', 'extra_specs'])
|
||||
shell_utils.print_list(vtypes, ['ID', 'Name', 'extra_specs'])
|
||||
|
||||
|
||||
@utils.arg('name',
|
||||
@ -821,7 +821,7 @@ def do_type_access_list(cs, args):
|
||||
access_list = cs.volume_type_access.list(volume_type)
|
||||
|
||||
columns = ['Volume_type_ID', 'Project_ID']
|
||||
utils.print_list(access_list, columns)
|
||||
shell_utils.print_list(access_list, columns)
|
||||
|
||||
|
||||
@utils.arg('--volume-type', metavar='<volume_type>', required=True,
|
||||
@ -972,7 +972,7 @@ def do_absolute_limits(cs, args):
|
||||
"""Lists absolute limits for a user."""
|
||||
limits = cs.limits.get(args.tenant).absolute
|
||||
columns = ['Name', 'Value']
|
||||
utils.print_list(limits, columns)
|
||||
shell_utils.print_list(limits, columns)
|
||||
|
||||
|
||||
@utils.arg('tenant',
|
||||
@ -984,7 +984,7 @@ def do_rate_limits(cs, args):
|
||||
"""Lists rate limits for a user."""
|
||||
limits = cs.limits.get(args.tenant).rate
|
||||
columns = ['Verb', 'URI', 'Value', 'Remain', 'Unit', 'Next_Available']
|
||||
utils.print_list(limits, columns)
|
||||
shell_utils.print_list(limits, columns)
|
||||
|
||||
|
||||
@utils.arg('volume',
|
||||
@ -1133,7 +1133,7 @@ def do_backup_create(cs, args):
|
||||
if 'links' in info:
|
||||
info.pop('links')
|
||||
|
||||
utils.print_dict(info)
|
||||
shell_utils.print_dict(info)
|
||||
|
||||
|
||||
@utils.arg('backup', metavar='<backup>', help='Name or ID of backup.')
|
||||
@ -1144,7 +1144,7 @@ def do_backup_show(cs, args):
|
||||
info.update(backup._info)
|
||||
|
||||
info.pop('links', None)
|
||||
utils.print_dict(info)
|
||||
shell_utils.print_dict(info)
|
||||
|
||||
|
||||
@utils.arg('--all-tenants',
|
||||
@ -1211,7 +1211,7 @@ def do_backup_list(cs, args):
|
||||
sortby_index = None
|
||||
else:
|
||||
sortby_index = 0
|
||||
utils.print_list(backups, columns, sortby_index=sortby_index)
|
||||
shell_utils.print_list(backups, columns, sortby_index=sortby_index)
|
||||
|
||||
|
||||
@utils.arg('--force',
|
||||
@ -1273,7 +1273,7 @@ def do_backup_restore(cs, args):
|
||||
|
||||
info.pop('links', None)
|
||||
|
||||
utils.print_dict(info)
|
||||
shell_utils.print_dict(info)
|
||||
|
||||
|
||||
@utils.arg('backup', metavar='<backup>',
|
||||
@ -1281,7 +1281,7 @@ def do_backup_restore(cs, args):
|
||||
def do_backup_export(cs, args):
|
||||
"""Export backup metadata record."""
|
||||
info = cs.backups.export_record(args.backup)
|
||||
utils.print_dict(info)
|
||||
shell_utils.print_dict(info)
|
||||
|
||||
|
||||
@utils.arg('backup_service', metavar='<backup_service>',
|
||||
@ -1293,7 +1293,7 @@ def do_backup_import(cs, args):
|
||||
info = cs.backups.import_record(args.backup_service, args.backup_url)
|
||||
info.pop('links', None)
|
||||
|
||||
utils.print_dict(info)
|
||||
shell_utils.print_dict(info)
|
||||
|
||||
|
||||
@utils.arg('backup', metavar='<backup>', nargs='+',
|
||||
@ -1345,7 +1345,7 @@ def do_transfer_create(cs, args):
|
||||
info.update(transfer._info)
|
||||
|
||||
info.pop('links', None)
|
||||
utils.print_dict(info)
|
||||
shell_utils.print_dict(info)
|
||||
|
||||
|
||||
@utils.arg('transfer', metavar='<transfer>',
|
||||
@ -1367,7 +1367,7 @@ def do_transfer_accept(cs, args):
|
||||
info.update(transfer._info)
|
||||
|
||||
info.pop('links', None)
|
||||
utils.print_dict(info)
|
||||
shell_utils.print_dict(info)
|
||||
|
||||
|
||||
@utils.arg('--all-tenants',
|
||||
@ -1391,7 +1391,7 @@ def do_transfer_list(cs, args):
|
||||
}
|
||||
transfers = cs.transfers.list(search_opts=search_opts)
|
||||
columns = ['ID', 'Volume ID', 'Name']
|
||||
utils.print_list(transfers, columns)
|
||||
shell_utils.print_list(transfers, columns)
|
||||
|
||||
|
||||
@utils.arg('transfer', metavar='<transfer>',
|
||||
@ -1403,7 +1403,7 @@ def do_transfer_show(cs, args):
|
||||
info.update(transfer._info)
|
||||
|
||||
info.pop('links', None)
|
||||
utils.print_dict(info)
|
||||
shell_utils.print_dict(info)
|
||||
|
||||
|
||||
@utils.arg('volume', metavar='<volume>',
|
||||
@ -1441,7 +1441,7 @@ def do_service_list(cs, args):
|
||||
# so as not to add the column when the extended ext is not enabled.
|
||||
if result and hasattr(result[0], 'disabled_reason'):
|
||||
columns.append("Disabled Reason")
|
||||
utils.print_list(result, columns)
|
||||
shell_utils.print_list(result, columns)
|
||||
|
||||
|
||||
@utils.arg('host', metavar='<hostname>', help='Host name.')
|
||||
@ -1450,7 +1450,7 @@ def do_service_enable(cs, args):
|
||||
"""Enables the service."""
|
||||
result = cs.services.enable(args.host, args.binary)
|
||||
columns = ["Host", "Binary", "Status"]
|
||||
utils.print_list([result], columns)
|
||||
shell_utils.print_list([result], columns)
|
||||
|
||||
|
||||
@utils.arg('host', metavar='<hostname>', help='Host name.')
|
||||
@ -1466,7 +1466,7 @@ def do_service_disable(cs, args):
|
||||
args.reason)
|
||||
else:
|
||||
result = cs.services.disable(args.host, args.binary)
|
||||
utils.print_list([result], columns)
|
||||
shell_utils.print_list([result], columns)
|
||||
|
||||
|
||||
def treeizeAvailabilityZone(zone):
|
||||
@ -1525,13 +1525,13 @@ def do_availability_zone_list(cs, _args):
|
||||
for zone in availability_zones:
|
||||
result += treeizeAvailabilityZone(zone)
|
||||
shell_utils.translate_availability_zone_keys(result)
|
||||
utils.print_list(result, ['Name', 'Status'])
|
||||
shell_utils.print_list(result, ['Name', 'Status'])
|
||||
|
||||
|
||||
def do_encryption_type_list(cs, args):
|
||||
"""Shows encryption type details for volume types. Admin only."""
|
||||
result = cs.volume_encryption_types.list()
|
||||
utils.print_list(result, ['Volume Type ID', 'Provider', 'Cipher',
|
||||
shell_utils.print_list(result, ['Volume Type ID', 'Provider', 'Cipher',
|
||||
'Key Size', 'Control Location'])
|
||||
|
||||
|
||||
@ -1796,7 +1796,7 @@ def do_snapshot_metadata(cs, args):
|
||||
|
||||
if args.action == 'set':
|
||||
metadata = snapshot.set_metadata(metadata)
|
||||
utils.print_dict(metadata._info)
|
||||
shell_utils.print_dict(metadata._info)
|
||||
elif args.action == 'unset':
|
||||
snapshot.delete_metadata(list(metadata.keys()))
|
||||
|
||||
@ -1806,7 +1806,7 @@ def do_snapshot_metadata(cs, args):
|
||||
def do_snapshot_metadata_show(cs, args):
|
||||
"""Shows snapshot metadata."""
|
||||
snapshot = shell_utils.find_volume_snapshot(cs, args.snapshot)
|
||||
utils.print_dict(snapshot._info['metadata'], 'Metadata-property')
|
||||
shell_utils.print_dict(snapshot._info['metadata'], 'Metadata-property')
|
||||
|
||||
|
||||
@utils.arg('volume', metavar='<volume>',
|
||||
@ -1814,7 +1814,7 @@ def do_snapshot_metadata_show(cs, args):
|
||||
def do_metadata_show(cs, args):
|
||||
"""Shows volume metadata."""
|
||||
volume = utils.find_volume(cs, args.volume)
|
||||
utils.print_dict(volume._info['metadata'], 'Metadata-property')
|
||||
shell_utils.print_dict(volume._info['metadata'], 'Metadata-property')
|
||||
|
||||
|
||||
@utils.arg('volume', metavar='<volume>',
|
||||
@ -1823,7 +1823,7 @@ def do_image_metadata_show(cs, args):
|
||||
"""Shows volume image metadata."""
|
||||
volume = utils.find_volume(cs, args.volume)
|
||||
resp, body = volume.show_image_metadata(volume)
|
||||
utils.print_dict(body['metadata'], 'Metadata-property')
|
||||
shell_utils.print_dict(body['metadata'], 'Metadata-property')
|
||||
|
||||
|
||||
@utils.arg('volume',
|
||||
@ -1839,7 +1839,7 @@ def do_metadata_update_all(cs, args):
|
||||
volume = utils.find_volume(cs, args.volume)
|
||||
metadata = shell_utils.extract_metadata(args)
|
||||
metadata = volume.update_all_metadata(metadata)
|
||||
utils.print_dict(metadata['metadata'], 'Metadata-property')
|
||||
shell_utils.print_dict(metadata['metadata'], 'Metadata-property')
|
||||
|
||||
|
||||
@utils.arg('snapshot',
|
||||
@ -1855,7 +1855,7 @@ def do_snapshot_metadata_update_all(cs, args):
|
||||
snapshot = shell_utils.find_volume_snapshot(cs, args.snapshot)
|
||||
metadata = shell_utils.extract_metadata(args)
|
||||
metadata = snapshot.update_all_metadata(metadata)
|
||||
utils.print_dict(metadata)
|
||||
shell_utils.print_dict(metadata)
|
||||
|
||||
|
||||
@utils.arg('volume', metavar='<volume>', help='ID of volume to update.')
|
||||
@ -1954,7 +1954,7 @@ def do_manage(cs, args):
|
||||
volume = cs.volumes.get(volume.id)
|
||||
info.update(volume._info)
|
||||
info.pop('links', None)
|
||||
utils.print_dict(info)
|
||||
shell_utils.print_dict(info)
|
||||
|
||||
|
||||
@utils.arg('volume', metavar='<volume>',
|
||||
@ -1978,7 +1978,7 @@ def do_consisgroup_list(cs, args):
|
||||
consistencygroups = cs.consistencygroups.list()
|
||||
|
||||
columns = ['ID', 'Status', 'Name']
|
||||
utils.print_list(consistencygroups, columns)
|
||||
shell_utils.print_list(consistencygroups, columns)
|
||||
|
||||
|
||||
@utils.arg('consistencygroup',
|
||||
@ -1992,7 +1992,7 @@ def do_consisgroup_show(cs, args):
|
||||
info.update(consistencygroup._info)
|
||||
|
||||
info.pop('links', None)
|
||||
utils.print_dict(info)
|
||||
shell_utils.print_dict(info)
|
||||
|
||||
|
||||
@utils.arg('volumetypes',
|
||||
@ -2023,7 +2023,7 @@ def do_consisgroup_create(cs, args):
|
||||
info.update(consistencygroup._info)
|
||||
|
||||
info.pop('links', None)
|
||||
utils.print_dict(info)
|
||||
shell_utils.print_dict(info)
|
||||
|
||||
|
||||
@utils.arg('--cgsnapshot',
|
||||
@ -2061,7 +2061,7 @@ def do_consisgroup_create_from_src(cs, args):
|
||||
args.description)
|
||||
|
||||
info.pop('links', None)
|
||||
utils.print_dict(info)
|
||||
shell_utils.print_dict(info)
|
||||
|
||||
|
||||
@utils.arg('consistencygroup',
|
||||
@ -2166,7 +2166,7 @@ def do_cgsnapshot_list(cs, args):
|
||||
cgsnapshots = cs.cgsnapshots.list(search_opts=search_opts)
|
||||
|
||||
columns = ['ID', 'Status', 'Name']
|
||||
utils.print_list(cgsnapshots, columns)
|
||||
shell_utils.print_list(cgsnapshots, columns)
|
||||
|
||||
|
||||
@utils.arg('cgsnapshot',
|
||||
@ -2179,7 +2179,7 @@ def do_cgsnapshot_show(cs, args):
|
||||
info.update(cgsnapshot._info)
|
||||
|
||||
info.pop('links', None)
|
||||
utils.print_dict(info)
|
||||
shell_utils.print_dict(info)
|
||||
|
||||
|
||||
@utils.arg('consistencygroup',
|
||||
@ -2207,7 +2207,7 @@ def do_cgsnapshot_create(cs, args):
|
||||
info.update(cgsnapshot._info)
|
||||
|
||||
info.pop('links', None)
|
||||
utils.print_dict(info)
|
||||
shell_utils.print_dict(info)
|
||||
|
||||
|
||||
@utils.arg('cgsnapshot',
|
||||
@ -2241,7 +2241,7 @@ def do_get_pools(cs, args):
|
||||
backend['name'] = info['name']
|
||||
if args.detail:
|
||||
backend.update(info['capabilities'])
|
||||
utils.print_dict(backend)
|
||||
shell_utils.print_dict(backend)
|
||||
|
||||
|
||||
@utils.arg('host',
|
||||
@ -2256,9 +2256,9 @@ def do_get_capabilities(cs, args):
|
||||
infos.update(capabilities._info)
|
||||
|
||||
prop = infos.pop('properties', None)
|
||||
utils.print_dict(infos, "Volume stats")
|
||||
utils.print_dict(prop, "Backend properties",
|
||||
formatters=sorted(prop.keys()))
|
||||
shell_utils.print_dict(infos, "Volume stats")
|
||||
shell_utils.print_dict(prop, "Backend properties",
|
||||
formatters=sorted(prop.keys()))
|
||||
|
||||
|
||||
@utils.arg('volume',
|
||||
@ -2308,7 +2308,7 @@ def do_snapshot_manage(cs, args):
|
||||
snapshot = cs.volume_snapshots.get(snapshot.id)
|
||||
info.update(snapshot._info)
|
||||
info.pop('links', None)
|
||||
utils.print_dict(info)
|
||||
shell_utils.print_dict(info)
|
||||
|
||||
|
||||
@utils.arg('snapshot', metavar='<snapshot>',
|
||||
@ -2378,7 +2378,7 @@ def do_manageable_list(cs, args):
|
||||
columns = ['reference', 'size', 'safe_to_manage']
|
||||
if detailed:
|
||||
columns.extend(['reason_not_safe', 'cinder_id', 'extra_info'])
|
||||
utils.print_list(volumes, columns, sortby_index=None)
|
||||
shell_utils.print_list(volumes, columns, sortby_index=None)
|
||||
|
||||
|
||||
@utils.arg('host',
|
||||
@ -2422,4 +2422,4 @@ def do_snapshot_manageable_list(cs, args):
|
||||
columns = ['reference', 'size', 'safe_to_manage', 'source_reference']
|
||||
if detailed:
|
||||
columns.extend(['reason_not_safe', 'cinder_id', 'extra_info'])
|
||||
utils.print_list(snapshots, columns, sortby_index=None)
|
||||
shell_utils.print_list(snapshots, columns, sortby_index=None)
|
||||
|
||||
Loading…
x
Reference in New Issue
Block a user