¡@
OpenStack Study: loadbalancer.py**** CubicPower OpenStack Study ****
# vim: tabstop=4 shiftwidth=4 softtabstop=4 # Copyright 2012 OpenStack Foundation. # All Rights Reserved. # # 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. import abc from oslo.config import cfg import six from neutron.api import extensions from neutron.api.v2 import attributes as attr from neutron.api.v2 import base from neutron.api.v2 import resource_helper from neutron.common import exceptions as qexception from neutron import manager from neutron.plugins.common import constants from neutron.services.service_base import ServicePluginBase # Loadbalancer Exceptions
**** CubicPower OpenStack Study **** class NoEligibleBackend(qexception.NotFound): message = _("No eligible backend for pool %(pool_id)s")
**** CubicPower OpenStack Study **** class VipNotFound(qexception.NotFound): message = _("Vip %(vip_id)s could not be found")
**** CubicPower OpenStack Study **** class VipExists(qexception.NeutronException): message = _("Another Vip already exists for pool %(pool_id)s")
**** CubicPower OpenStack Study **** class PoolNotFound(qexception.NotFound): message = _("Pool %(pool_id)s could not be found")
**** CubicPower OpenStack Study **** class MemberNotFound(qexception.NotFound): message = _("Member %(member_id)s could not be found")
**** CubicPower OpenStack Study **** class HealthMonitorNotFound(qexception.NotFound): message = _("Health_monitor %(monitor_id)s could not be found")
**** CubicPower OpenStack Study **** class PoolMonitorAssociationNotFound(qexception.NotFound): message = _("Monitor %(monitor_id)s is not associated " "with Pool %(pool_id)s")
**** CubicPower OpenStack Study **** class PoolMonitorAssociationExists(qexception.Conflict): message = _('health_monitor %(monitor_id)s is already associated ' 'with pool %(pool_id)s')
**** CubicPower OpenStack Study **** class StateInvalid(qexception.NeutronException): message = _("Invalid state %(state)s of Loadbalancer resource %(id)s")
**** CubicPower OpenStack Study **** class PoolInUse(qexception.InUse): message = _("Pool %(pool_id)s is still in use")
**** CubicPower OpenStack Study **** class HealthMonitorInUse(qexception.InUse): message = _("Health monitor %(monitor_id)s still has associations with " "pools")
**** CubicPower OpenStack Study **** class PoolStatsNotFound(qexception.NotFound): message = _("Statistics of Pool %(pool_id)s could not be found")
**** CubicPower OpenStack Study **** class ProtocolMismatch(qexception.BadRequest): message = _("Protocol %(vip_proto)s does not match " "pool protocol %(pool_proto)s")
**** CubicPower OpenStack Study **** class MemberExists(qexception.NeutronException): message = _("Member with address %(address)s and port %(port)s " "already present in pool %(pool)s") RESOURCE_ATTRIBUTE_MAP = { 'vips': { 'id': {'allow_post': False, 'allow_put': False, 'validate': {'type:uuid': None}, 'is_visible': True, 'primary_key': True}, 'tenant_id': {'allow_post': True, 'allow_put': False, 'validate': {'type:string': None}, 'required_by_policy': True, 'is_visible': True}, 'name': {'allow_post': True, 'allow_put': True, 'validate': {'type:string': None}, '
**** CubicPower OpenStack Study **** class Loadbalancer(extensions.ExtensionDescriptor): @classmethod
**** CubicPower OpenStack Study **** def get_name(cls): return "LoadBalancing service" @classmethod
**** CubicPower OpenStack Study **** def get_alias(cls): return "lbaas" @classmethod
**** CubicPower OpenStack Study **** def get_description(cls): return "Extension for LoadBalancing service" @classmethod
**** CubicPower OpenStack Study **** def get_namespace(cls): return "http://wiki.openstack.org/neutron/LBaaS/API_1.0" @classmethod
**** CubicPower OpenStack Study **** def get_updated(cls): return "2012-10-07T10:00:00-00:00" @classmethod
**** CubicPower OpenStack Study **** def get_resources(cls): plural_mappings = resource_helper.build_plural_mappings( {}, RESOURCE_ATTRIBUTE_MAP) plural_mappings['health_monitors_status'] = 'health_monitor_status' attr.PLURALS.update(plural_mappings) action_map = {'pool': {'stats': 'GET'}} resources = resource_helper.build_resource_info(plural_mappings, RESOURCE_ATTRIBUTE_MAP, constants.LOADBALANCER, action_map=action_map) plugin = manager.NeutronManager.get_service_plugins()[ constants.LOADBALANCER] for collection_name in SUB_RESOURCE_ATTRIBUTE_MAP: # Special handling needed for sub-resources with 'y' ending # (e.g. proxies -> proxy) resource_name = collection_name[:-1] parent = SUB_RESOURCE_ATTRIBUTE_MAP[collection_name].get('parent') params = SUB_RESOURCE_ATTRIBUTE_MAP[collection_name].get( 'parameters') controller = base.create_resource(collection_name, resource_name, plugin, params, allow_bulk=True, parent=parent) resource = extensions.ResourceExtension( collection_name, controller, parent, path_prefix=constants.COMMON_PREFIXES[constants.LOADBALANCER], attr_map=params) resources.append(resource) return resources @classmethod
**** CubicPower OpenStack Study **** def get_plugin_interface(cls): return LoadBalancerPluginBase
**** CubicPower OpenStack Study **** def update_attributes_map(self, attributes): super(Loadbalancer, self).update_attributes_map( attributes, extension_attrs_map=RESOURCE_ATTRIBUTE_MAP)
**** CubicPower OpenStack Study **** def get_extended_resources(self, version): if version == "2.0": return RESOURCE_ATTRIBUTE_MAP else: return {} @six.add_metaclass(abc.ABCMeta)
**** CubicPower OpenStack Study **** class LoadBalancerPluginBase(ServicePluginBase):
**** CubicPower OpenStack Study **** def get_plugin_name(self): return constants.LOADBALANCER
**** CubicPower OpenStack Study **** def get_plugin_type(self): return constants.LOADBALANCER
**** CubicPower OpenStack Study **** def get_plugin_description(self): return 'LoadBalancer service plugin' @abc.abstractmethod
**** CubicPower OpenStack Study **** def get_vips(self, context, filters=None, fields=None): pass @abc.abstractmethod
**** CubicPower OpenStack Study **** def get_vip(self, context, id, fields=None): pass @abc.abstractmethod
**** CubicPower OpenStack Study **** def create_vip(self, context, vip): pass @abc.abstractmethod
**** CubicPower OpenStack Study **** def update_vip(self, context, id, vip): pass @abc.abstractmethod
**** CubicPower OpenStack Study **** def delete_vip(self, context, id): pass @abc.abstractmethod
**** CubicPower OpenStack Study **** def get_pools(self, context, filters=None, fields=None): pass @abc.abstractmethod
**** CubicPower OpenStack Study **** def get_pool(self, context, id, fields=None): pass @abc.abstractmethod
**** CubicPower OpenStack Study **** def create_pool(self, context, pool): pass @abc.abstractmethod
**** CubicPower OpenStack Study **** def update_pool(self, context, id, pool): pass @abc.abstractmethod
**** CubicPower OpenStack Study **** def delete_pool(self, context, id): pass @abc.abstractmethod
**** CubicPower OpenStack Study **** def stats(self, context, pool_id): pass @abc.abstractmethod
**** CubicPower OpenStack Study **** def create_pool_health_monitor(self, context, health_monitor, pool_id): pass @abc.abstractmethod
**** CubicPower OpenStack Study **** def get_pool_health_monitor(self, context, id, pool_id, fields=None): pass @abc.abstractmethod
**** CubicPower OpenStack Study **** def delete_pool_health_monitor(self, context, id, pool_id): pass @abc.abstractmethod
**** CubicPower OpenStack Study **** def get_members(self, context, filters=None, fields=None): pass @abc.abstractmethod
**** CubicPower OpenStack Study **** def get_member(self, context, id, fields=None): pass @abc.abstractmethod
**** CubicPower OpenStack Study **** def create_member(self, context, member): pass @abc.abstractmethod
**** CubicPower OpenStack Study **** def update_member(self, context, id, member): pass @abc.abstractmethod
**** CubicPower OpenStack Study **** def delete_member(self, context, id): pass @abc.abstractmethod
**** CubicPower OpenStack Study **** def get_health_monitors(self, context, filters=None, fields=None): pass @abc.abstractmethod
**** CubicPower OpenStack Study **** def get_health_monitor(self, context, id, fields=None): pass @abc.abstractmethod
**** CubicPower OpenStack Study **** def create_health_monitor(self, context, health_monitor): pass @abc.abstractmethod
**** CubicPower OpenStack Study **** def update_health_monitor(self, context, id, health_monitor): pass @abc.abstractmethod
**** CubicPower OpenStack Study **** def delete_health_monitor(self, context, id): pass
|