Merge "Add volume support for openstack client"
This commit is contained in:
commit
6fae83b935
216
openstackclient/volume/v1/volume.py
Normal file
216
openstackclient/volume/v1/volume.py
Normal file
@ -0,0 +1,216 @@
|
|||||||
|
# Copyright 2012-2013 OpenStack, LLC.
|
||||||
|
#
|
||||||
|
# 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.
|
||||||
|
#
|
||||||
|
|
||||||
|
"""Volume v1 Volume action implementations"""
|
||||||
|
|
||||||
|
import logging
|
||||||
|
import sys
|
||||||
|
|
||||||
|
from cliff import command
|
||||||
|
from cliff import lister
|
||||||
|
from cliff import show
|
||||||
|
|
||||||
|
from openstackclient.common import utils
|
||||||
|
|
||||||
|
|
||||||
|
class CreateVolume(show.ShowOne):
|
||||||
|
"""Create volume command"""
|
||||||
|
|
||||||
|
api = 'volume'
|
||||||
|
log = logging.getLogger(__name__ + '.CreateVolume')
|
||||||
|
|
||||||
|
def get_parser(self, prog_name):
|
||||||
|
parser = super(CreateVolume, self).get_parser(prog_name)
|
||||||
|
parser.add_argument(
|
||||||
|
'name',
|
||||||
|
metavar='<name>',
|
||||||
|
help='Name of the volume',
|
||||||
|
)
|
||||||
|
parser.add_argument(
|
||||||
|
'--size',
|
||||||
|
metavar='<size>',
|
||||||
|
required=True,
|
||||||
|
type=int,
|
||||||
|
help='New volume size',
|
||||||
|
)
|
||||||
|
parser.add_argument(
|
||||||
|
'--snapshot-id',
|
||||||
|
metavar='<snapshot-id>',
|
||||||
|
help='ID of the snapshot',
|
||||||
|
)
|
||||||
|
parser.add_argument(
|
||||||
|
'--description',
|
||||||
|
metavar='<description>',
|
||||||
|
help='Description of the volume',
|
||||||
|
)
|
||||||
|
parser.add_argument(
|
||||||
|
'--volume-type',
|
||||||
|
metavar='<volume-type>',
|
||||||
|
help='Type of volume',
|
||||||
|
)
|
||||||
|
parser.add_argument(
|
||||||
|
'--user-id',
|
||||||
|
metavar='<user-id>',
|
||||||
|
help='User id derived from context',
|
||||||
|
)
|
||||||
|
parser.add_argument(
|
||||||
|
'--project-id',
|
||||||
|
metavar='<project-id>',
|
||||||
|
help='Project id derived from context',
|
||||||
|
)
|
||||||
|
parser.add_argument(
|
||||||
|
'--availability-zone',
|
||||||
|
metavar='<availability-zone>',
|
||||||
|
help='Availability Zone to use',
|
||||||
|
)
|
||||||
|
parser.add_argument(
|
||||||
|
'--metadata',
|
||||||
|
metavar='<metadata>',
|
||||||
|
help='Optional metadata to set on volume creation',
|
||||||
|
)
|
||||||
|
parser.add_argument(
|
||||||
|
'--image-ref',
|
||||||
|
metavar='<image-ref>',
|
||||||
|
help='reference to an image stored in glance',
|
||||||
|
)
|
||||||
|
parser.add_argument(
|
||||||
|
'--source-volid',
|
||||||
|
metavar='<source-volid>',
|
||||||
|
help='ID of source volume to clone from',
|
||||||
|
)
|
||||||
|
|
||||||
|
return parser
|
||||||
|
|
||||||
|
def take_action(self, parsed_args):
|
||||||
|
self.log.debug('take_action(%s)' % parsed_args)
|
||||||
|
|
||||||
|
volume_client = self.app.client_manager.volume
|
||||||
|
volume = volume_client.volumes.create(
|
||||||
|
parsed_args.size,
|
||||||
|
parsed_args.snapshot_id,
|
||||||
|
parsed_args.source_volid,
|
||||||
|
parsed_args.name,
|
||||||
|
parsed_args.description,
|
||||||
|
parsed_args.volume_type,
|
||||||
|
parsed_args.user_id,
|
||||||
|
parsed_args.project_id,
|
||||||
|
parsed_args.availability_zone,
|
||||||
|
parsed_args.metadata,
|
||||||
|
parsed_args.image_ref
|
||||||
|
)
|
||||||
|
|
||||||
|
return zip(*sorted(volume._info.iteritems()))
|
||||||
|
|
||||||
|
|
||||||
|
class DeleteVolume(command.Command):
|
||||||
|
"""Delete volume command"""
|
||||||
|
|
||||||
|
api = 'volume'
|
||||||
|
log = logging.getLogger(__name__ + '.DeleteVolume')
|
||||||
|
|
||||||
|
def get_parser(self, prog_name):
|
||||||
|
parser = super(DeleteVolume, self).get_parser(prog_name)
|
||||||
|
parser.add_argument(
|
||||||
|
'volume',
|
||||||
|
metavar='<volume>',
|
||||||
|
help='ID of volume to delete',
|
||||||
|
)
|
||||||
|
return parser
|
||||||
|
|
||||||
|
def take_action(self, parsed_args):
|
||||||
|
self.log.debug('take_action(%s)' % parsed_args)
|
||||||
|
volume_client = self.app.client_manager.volume
|
||||||
|
volume = utils.find_resource(
|
||||||
|
volume_client.volumes, parsed_args.volume)
|
||||||
|
volume_client.volumes.delete(volume.id)
|
||||||
|
return
|
||||||
|
|
||||||
|
|
||||||
|
class ListVolume(lister.Lister):
|
||||||
|
"""List volume command"""
|
||||||
|
|
||||||
|
api = 'volume'
|
||||||
|
log = logging.getLogger(__name__ + '.ListVolume')
|
||||||
|
|
||||||
|
def take_action(self, parsed_args):
|
||||||
|
self.log.debug('take_action(%s)' % parsed_args)
|
||||||
|
columns = ('ID', 'Status', 'Display Name', 'Size', 'Volume Type')
|
||||||
|
data = self.app.client_manager.volume.volumes.list()
|
||||||
|
return (columns,
|
||||||
|
(utils.get_item_properties(
|
||||||
|
s, columns,
|
||||||
|
formatters={},
|
||||||
|
) for s in data))
|
||||||
|
|
||||||
|
|
||||||
|
class SetVolume(command.Command):
|
||||||
|
"""Set volume command"""
|
||||||
|
|
||||||
|
api = 'volume'
|
||||||
|
log = logging.getLogger(__name__ + '.SetVolume')
|
||||||
|
|
||||||
|
def get_parser(self, prog_name):
|
||||||
|
parser = super(SetVolume, self).get_parser(prog_name)
|
||||||
|
parser.add_argument(
|
||||||
|
'volume',
|
||||||
|
metavar='<volume>',
|
||||||
|
help='ID of volume to change')
|
||||||
|
parser.add_argument(
|
||||||
|
'--name',
|
||||||
|
metavar='<new-volume-name>',
|
||||||
|
help='New volume name')
|
||||||
|
parser.add_argument(
|
||||||
|
'--description',
|
||||||
|
metavar='<volume-description>',
|
||||||
|
help='New volume description')
|
||||||
|
return parser
|
||||||
|
|
||||||
|
def take_action(self, parsed_args):
|
||||||
|
self.log.debug('take_action(%s)' % parsed_args)
|
||||||
|
volume_client = self.app.client_manager.volume
|
||||||
|
volume = utils.find_resource(volume_client.volumes, parsed_args.volume)
|
||||||
|
kwargs = {}
|
||||||
|
if parsed_args.name:
|
||||||
|
kwargs['display_name'] = parsed_args.name
|
||||||
|
if parsed_args.description:
|
||||||
|
kwargs['display_description'] = parsed_args.description
|
||||||
|
|
||||||
|
if not kwargs:
|
||||||
|
sys.stdout.write("Volume not updated, no arguments present \n")
|
||||||
|
return
|
||||||
|
volume_client.volumes.update(volume.id, **kwargs)
|
||||||
|
return
|
||||||
|
|
||||||
|
|
||||||
|
class ShowVolume(show.ShowOne):
|
||||||
|
"""Show volume command"""
|
||||||
|
|
||||||
|
api = 'volume'
|
||||||
|
log = logging.getLogger(__name__ + '.ShowVolume')
|
||||||
|
|
||||||
|
def get_parser(self, prog_name):
|
||||||
|
parser = super(ShowVolume, self).get_parser(prog_name)
|
||||||
|
parser.add_argument(
|
||||||
|
'volume',
|
||||||
|
metavar='<volume>',
|
||||||
|
help='ID of volume to display')
|
||||||
|
return parser
|
||||||
|
|
||||||
|
def take_action(self, parsed_args):
|
||||||
|
self.log.debug('take_action(%s)' % parsed_args)
|
||||||
|
volume_client = self.app.client_manager.volume
|
||||||
|
volume = utils.find_resource(volume_client.volumes, parsed_args.volume)
|
||||||
|
|
||||||
|
return zip(*sorted(volume._info.iteritems()))
|
5
setup.py
5
setup.py
@ -156,6 +156,11 @@ setuptools.setup(
|
|||||||
'show_quota=openstackclient.volume.v1.quota:ShowQuota',
|
'show_quota=openstackclient.volume.v1.quota:ShowQuota',
|
||||||
'list_quota=openstackclient.volume.v1.quota:ListQuota',
|
'list_quota=openstackclient.volume.v1.quota:ListQuota',
|
||||||
'set_quota=openstackclient.volume.v1.quota:SetQuota',
|
'set_quota=openstackclient.volume.v1.quota:SetQuota',
|
||||||
|
'create_volume=openstackclient.volume.v1.volume:CreateVolume',
|
||||||
|
'delete_volume=openstackclient.volume.v1.volume:DeleteVolume',
|
||||||
|
'list_volume=openstackclient.volume.v1.volume:ListVolume',
|
||||||
|
'set_volume=openstackclient.volume.v1.volume:SetVolume',
|
||||||
|
'show_volume=openstackclient.volume.v1.volume:ShowVolume',
|
||||||
]
|
]
|
||||||
}
|
}
|
||||||
)
|
)
|
||||||
|
Loading…
x
Reference in New Issue
Block a user