diff options
author | Yao Lu <lu.yao135@zte.com.cn> | 2016-12-23 11:39:53 +0800 |
---|---|---|
committer | Yao Lu <lu.yao135@zte.com.cn> | 2017-03-03 07:24:04 +0000 |
commit | c1783221873845d072b739c7ebd8d0a75fe00bb9 (patch) | |
tree | b1feebd61bf662b1759c3d3a272884e3803083d5 /client | |
parent | ebde2dafb975d047e9739874c9cabe4ccc7df7e8 (diff) |
use command escalator version and tox genconfig
Change-Id: I78e15e4224b362c6737786a7f6a7d127b82596ce
Signed-off-by: Yao Lu <lu.yao135@zte.com.cn>
Diffstat (limited to 'client')
-rw-r--r-- | client/escalatorclient/v1/client.py | 2 | ||||
-rw-r--r-- | client/escalatorclient/v1/shell.py | 98 | ||||
-rw-r--r-- | client/escalatorclient/v1/versions.py | 80 |
3 files changed, 5 insertions, 175 deletions
diff --git a/client/escalatorclient/v1/client.py b/client/escalatorclient/v1/client.py index f74300f..d5bf6bc 100644 --- a/client/escalatorclient/v1/client.py +++ b/client/escalatorclient/v1/client.py @@ -33,4 +33,4 @@ class Client(object): endpoint, version = utils.strip_version(endpoint) self.version = version or 1.0 self.http_client = http.HTTPClient(endpoint, *args, **kwargs) - self.node = VersionManager(self.http_client) + self.versions = VersionManager(self.http_client) diff --git a/client/escalatorclient/v1/shell.py b/client/escalatorclient/v1/shell.py index fbc2459..401ad76 100644 --- a/client/escalatorclient/v1/shell.py +++ b/client/escalatorclient/v1/shell.py @@ -17,11 +17,9 @@ from __future__ import print_function import copy import functools -from oslo_utils import encodeutils from oslo_utils import strutils import escalatorclient.v1.versions from escalatorclient.common import utils -from escalatorclient import exc _bool_strict = functools.partial(strutils.bool_from_string, strict=True) @@ -43,96 +41,12 @@ def do_version(dc, args): fields = dict(filter(lambda x: x[1] is not None, vars(args).items())) # Filter out values we can't use - VERSION_PARAMS = escalatorclient.v1.version.VERSION_PARAMS + VERSION_PARAMS = escalatorclient.v1.versions.VERSION_PARAMS fields = dict(filter(lambda x: x[0] in VERSION_PARAMS, fields.items())) - version = dc.version.version(**fields) + version = dc.versions.version(**fields) _escalator_show(version) -@utils.arg('id', metavar='<ID>', - help='Filter version to those that have this id.') -def do_version_detail(dc, args): - """Get backend_types of escalator.""" - version = utils.find_resource(dc.versions, args.id) - _escalator_show(version) - - -@utils.arg('name', metavar='<NAME>', - help='name of version.') -@utils.arg('type', metavar='<TYPE>', - help='version type.eg redhat7.0...') -@utils.arg('--size', metavar='<SIZE>', - help='size of the version file.') -@utils.arg('--checksum', metavar='<CHECKSUM>', - help='md5 of version file') -@utils.arg('--version', metavar='<VERSION>', - help='version number of version file') -@utils.arg('--description', metavar='<DESCRIPTION>', - help='description of version file') -@utils.arg('--status', metavar='<STATUS>', - help='version file status.default:init') -def do_version_add(dc, args): - """Add a version.""" - - fields = dict(filter(lambda x: x[1] is not None, vars(args).items())) - - # Filter out values we can't use - CREATE_PARAMS = escalatorclient.v1.versions.CREATE_PARAMS - fields = dict(filter(lambda x: x[0] in CREATE_PARAMS, fields.items())) - - version = dc.versions.add(**fields) - _escalator_show(version) - - -@utils.arg('id', metavar='<ID>', - help='ID of versions.') -@utils.arg('--name', metavar='<NAME>', - help='name of version.') -@utils.arg('--type', metavar='<TYPE>', - help='version type.eg redhat7.0...') -@utils.arg('--size', metavar='<SIZE>', - help='size of the version file.') -@utils.arg('--checksum', metavar='<CHECKSUM>', - help='md5 of version file') -@utils.arg('--version', metavar='<VERSION>', - help='version number of version file') -@utils.arg('--description', metavar='<DESCRIPTION>', - help='description of version file') -@utils.arg('--status', metavar='<STATUS>', - help='version file status.default:init') -def do_version_update(dc, args): - """Add a version.""" - - fields = dict(filter(lambda x: x[1] is not None, vars(args).items())) - - # Filter out values we can't use - CREATE_PARAMS = escalatorclient.v1.versions.CREATE_PARAMS - fields = dict(filter(lambda x: x[0] in CREATE_PARAMS, fields.items())) - version_id = fields.get('id', None) - version = dc.versions.update(version_id, **fields) - _escalator_show(version) - - -@utils.arg('id', metavar='<ID>', nargs='+', - help='ID of versions.') -def do_version_delete(dc, args): - """Delete specified template(s).""" - fields = dict(filter(lambda x: x[1] is not None, vars(args).items())) - versions = fields.get('id', None) - for version in versions: - try: - if args.verbose: - print('Requesting version delete for %s ...' % - encodeutils.safe_decode(version), end=' ') - dc.versions.delete(version) - if args.verbose: - print('[Done]') - except exc.HTTPException as e: - if args.verbose: - print('[Fail]') - print('%s: Unable to delete version %s' % (e, version)) - - @utils.arg('--name', metavar='<NAME>', help='Filter version to those that have this name.') @utils.arg('--status', metavar='<STATUS>', @@ -168,11 +82,3 @@ def do_cluster_version_list(dc, args): 'checksum', 'description', 'status', 'VERSION_PATCH'] utils.print_list(versions, columns) - - -@utils.arg('id', metavar='<ID>', - help='Filter version patch to those that have this id.') -def do_version_patch_detail(dc, args): - """Get version_patch of escalator.""" - version = utils.find_resource(dc.version_patchs, args.id) - _escalator_show(version) diff --git a/client/escalatorclient/v1/versions.py b/client/escalatorclient/v1/versions.py index f98a3ed..143c4c6 100644 --- a/client/escalatorclient/v1/versions.py +++ b/client/escalatorclient/v1/versions.py @@ -105,23 +105,6 @@ class VersionManager(base.ManagerWithFind): pass return meta - def get(self, version, **kwargs): - """Get the metadata for a specific version. - - :param version: image object or id to look up - :rtype: :class:`version` - """ - version_id = base.getid(version) - resp, body = self.client.get('/v1/versions/%s' - % urlparse.quote(str(version_id))) - # meta = self._version_meta_from_headers(resp.headers) - return_request_id = kwargs.get('return_req_id', None) - if return_request_id is not None: - return_request_id.append(resp.headers.get(OS_REQ_ID_HDR, None)) - # return version(self, meta) - return Version(self, self._format_version_meta_for_user( - body['version'])) - def _build_params(self, parameters): params = {'limit': parameters.get('page_size', DEFAULT_PAGE_SIZE)} @@ -223,65 +206,6 @@ class VersionManager(base.ManagerWithFind): params['marker'] = last_version seen_last_page = 0 - def add(self, **kwargs): - """Add a version - - TODO(bcwaldon): document accepted params - """ - - fields = {} - for field in kwargs: - if field in CREATE_PARAMS: - fields[field] = kwargs[field] - elif field == 'return_req_id': - continue - else: - msg = 'create() got an unexpected keyword argument \'%s\'' - raise TypeError(msg % field) - - hdrs = self._version_meta_to_headers(fields) - - resp, body = self.client.post('/v1/versions', - headers=None, - data=hdrs) - return_request_id = kwargs.get('return_req_id', None) - if return_request_id is not None: - return_request_id.append(resp.headers.get(OS_REQ_ID_HDR, None)) - - return Version(self, self._format_version_meta_for_user( - body['version'])) - - def delete(self, version, **kwargs): - """Delete an version.""" - url = "/v1/versions/%s" % base.getid(version) - resp, body = self.client.delete(url) - return_request_id = kwargs.get('return_req_id', None) - if return_request_id is not None: - return_request_id.append(resp.headers.get(OS_REQ_ID_HDR, None)) - - def update(self, version, **kwargs): - """Update an version - - TODO(bcwaldon): document accepted params - """ - hdrs = {} - fields = {} - for field in kwargs: - if field in CREATE_PARAMS: - fields[field] = kwargs[field] - elif field == 'return_req_id': - continue - hdrs.update(self._version_meta_to_headers(fields)) - - url = '/v1/versions/%s' % base.getid(version) - resp, body = self.client.put(url, headers=None, data=hdrs) - return_request_id = kwargs.get('return_req_id', None) - if return_request_id is not None: - return_request_id.append(resp.headers.get(OS_REQ_ID_HDR, None)) - - return Version(self, self._format_version_meta_for_user( - body['version_meta'])) - def version(self, **kwargs): """Get internal or external version of escalator. @@ -295,7 +219,7 @@ class VersionManager(base.ManagerWithFind): msg = 'install() got an unexpected keyword argument \'%s\'' raise TypeError(msg % field) - url = '/v1/version' - hdrs = self._restore_meta_to_headers(fields) + url = '/v1/versions' + hdrs = self._version_meta_to_headers(fields) resp, body = self.client.post(url, headers=None, data=hdrs) return Version(self, body) |