¡@
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 import compute from nova.objects import base as obj_base ALIAS = "os-migrations"
**** CubicPower OpenStack Study **** def authorize(context, action_name): action = 'v3:%s:%s' % (ALIAS, 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 MigrationsController(object): """Controller for accessing migrations in OpenStack API."""
**** CubicPower OpenStack Study **** def __init__(self): self.compute_api = compute.API() @extensions.expected_errors(())
**** 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.V3APIExtensionBase): """Provide data on migrations.""" name = "Migrations" alias = ALIAS version = 1
**** CubicPower OpenStack Study **** def get_resources(self): resources = [] resource = extensions.ResourceExtension('os-migrations', MigrationsController()) resources.append(resource) return resources
**** CubicPower OpenStack Study **** def get_controller_extensions(self): return []
|