¡@
OpenStack Study: migrations.py**** CubicPower OpenStack Study ****
# 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. from nova.api.openstack import extensions from nova.api.openstack import wsgi from nova.api.openstack import xmlutil from nova import compute from nova.objects import base as obj_base XMLNS = "http://docs.openstack.org/compute/ext/migrations/api/v2.0" ALIAS = "os-migrations"
**** CubicPower OpenStack Study **** def authorize(context, action_name): action = 'migrations:%s' % action_name extensions.extension_authorizer('compute', action)(context)
**** CubicPower OpenStack Study **** def output(migrations_obj): """Returns the desired output of the API from an object. From a MigrationsList's object this method returns a list of primitive objects with the only necessary fields. """ objects = obj_base.obj_to_primitive(migrations_obj) for obj in objects: del obj['deleted'] del obj['deleted_at'] return objects
**** CubicPower OpenStack Study **** class MigrationsTemplate(xmlutil.TemplateBuilder):
**** CubicPower OpenStack Study **** def construct(self): root = xmlutil.TemplateElement('migrations') elem = xmlutil.SubTemplateElement(root, 'migration', selector='migrations') elem.set('id') elem.set('source_node') elem.set('dest_node') elem.set('source_compute') elem.set('dest_compute') elem.set('dest_host') elem.set('status') elem.set('instance_uuid') elem.set('old_instance_type_id') elem.set('new_instance_type_id') elem.set('created_at') elem.set('updated_at') return xmlutil.MasterTemplate(root, 1)
**** CubicPower OpenStack Study **** class MigrationsController(object): """Controller for accessing migrations in OpenStack API."""
**** CubicPower OpenStack Study **** def __init__(self): self.compute_api = compute.API() @wsgi.serializers(xml=MigrationsTemplate)
**** CubicPower OpenStack Study **** def index(self, req): """Return all migrations in progress.""" context = req.environ['nova.context'] authorize(context, "index") migrations = self.compute_api.get_migrations(context, req.GET) return {'migrations': output(migrations)}
**** CubicPower OpenStack Study **** class Migrations(extensions.ExtensionDescriptor): """Provide data on migrations.""" name = "Migrations" alias = ALIAS namespace = XMLNS updated = "2013-05-30T00:00:00+00:00"
**** CubicPower OpenStack Study **** def get_resources(self): resources = [] resource = extensions.ResourceExtension('os-migrations', MigrationsController()) resources.append(resource) return resources
|