¡@
OpenStack Study: l3.py**** CubicPower OpenStack Study ****
# 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. from abc import abstractmethod from oslo.config import cfg from neutron.api import extensions from neutron.api.v2 import attributes as attr from neutron.api.v2 import resource_helper from neutron.common import exceptions as qexception from neutron.plugins.common import constants # L3 Exceptions
**** CubicPower OpenStack Study **** class RouterNotFound(qexception.NotFound): message = _("Router %(router_id)s could not be found")
**** CubicPower OpenStack Study **** class RouterInUse(qexception.InUse): message = _("Router %(router_id)s still has ports")
**** CubicPower OpenStack Study **** class RouterInterfaceNotFound(qexception.NotFound): message = _("Router %(router_id)s does not have " "an interface with id %(port_id)s")
**** CubicPower OpenStack Study **** class RouterInterfaceNotFoundForSubnet(qexception.NotFound): message = _("Router %(router_id)s has no interface " "on subnet %(subnet_id)s")
**** CubicPower OpenStack Study **** class RouterInterfaceInUseByFloatingIP(qexception.InUse): message = _("Router interface for subnet %(subnet_id)s on router " "%(router_id)s cannot be deleted, as it is required " "by one or more floating IPs.")
**** CubicPower OpenStack Study **** class FloatingIPNotFound(qexception.NotFound): message = _("Floating IP %(floatingip_id)s could not be found")
**** CubicPower OpenStack Study **** class ExternalGatewayForFloatingIPNotFound(qexception.NotFound): message = _("External network %(external_network_id)s is not reachable " "from subnet %(subnet_id)s. Therefore, cannot associate " "Port %(port_id)s with a Floating IP.")
**** CubicPower OpenStack Study **** class FloatingIPPortAlreadyAssociated(qexception.InUse): message = _("Cannot associate floating IP %(floating_ip_address)s " "(%(fip_id)s) with port %(port_id)s " "using fixed IP %(fixed_ip)s, as that fixed IP already " "has a floating IP on external network %(net_id)s.")
**** CubicPower OpenStack Study **** class L3PortInUse(qexception.InUse): message = _("Port %(port_id)s has owner %(device_owner)s and therefore" " cannot be deleted directly via the port API.")
**** CubicPower OpenStack Study **** class RouterExternalGatewayInUseByFloatingIp(qexception.InUse): message = _("Gateway cannot be updated for router %(router_id)s, since a " "gateway to external network %(net_id)s is required by one or " "more floating IPs.") ROUTERS = 'routers' EXTERNAL_GW_INFO = 'external_gateway_info' RESOURCE_ATTRIBUTE_MAP = { ROUTERS: { 'id': {'allow_post': False, 'allow_put': False, 'validate': {'type:uuid': None}, 'is_visible': True, 'primary_key': True}, 'name': {'allow_post': True, 'allow_put': True, 'validate': {'type:string': None}, 'is_visible': True, '
**** CubicPower OpenStack Study **** class L3(extensions.ExtensionDescriptor): @classmethod
**** CubicPower OpenStack Study **** def get_name(cls): return "Neutron L3 Router" @classmethod
**** CubicPower OpenStack Study **** def get_alias(cls): return "router" @classmethod
**** CubicPower OpenStack Study **** def get_description(cls): return ("Router abstraction for basic L3 forwarding" " between L2 Neutron networks and access to external" " networks via a NAT gateway.") @classmethod
**** CubicPower OpenStack Study **** def get_namespace(cls): return "http://docs.openstack.org/ext/neutron/router/api/v1.0" @classmethod
**** CubicPower OpenStack Study **** def get_updated(cls): return "2012-07-20T10:00:00-00:00" @classmethod
**** CubicPower OpenStack Study **** def get_resources(cls): """Returns Ext Resources.""" plural_mappings = resource_helper.build_plural_mappings( {}, RESOURCE_ATTRIBUTE_MAP) attr.PLURALS.update(plural_mappings) action_map = {'router': {'add_router_interface': 'PUT', 'remove_router_interface': 'PUT'}} return resource_helper.build_resource_info(plural_mappings, RESOURCE_ATTRIBUTE_MAP, constants.L3_ROUTER_NAT, action_map=action_map, register_quota=True)
**** CubicPower OpenStack Study **** def update_attributes_map(self, attributes): super(L3, 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 {}
**** CubicPower OpenStack Study **** class RouterPluginBase(object): @abstractmethod
**** CubicPower OpenStack Study **** def create_router(self, context, router): pass @abstractmethod
**** CubicPower OpenStack Study **** def update_router(self, context, id, router): pass @abstractmethod
**** CubicPower OpenStack Study **** def get_router(self, context, id, fields=None): pass @abstractmethod
**** CubicPower OpenStack Study **** def delete_router(self, context, id): pass @abstractmethod
**** CubicPower OpenStack Study **** def get_routers(self, context, filters=None, fields=None, sorts=None, limit=None, marker=None, page_reverse=False): pass @abstractmethod
**** CubicPower OpenStack Study **** def add_router_interface(self, context, router_id, interface_info): pass @abstractmethod
**** CubicPower OpenStack Study **** def remove_router_interface(self, context, router_id, interface_info): pass @abstractmethod
**** CubicPower OpenStack Study **** def create_floatingip(self, context, floatingip): pass @abstractmethod
**** CubicPower OpenStack Study **** def update_floatingip(self, context, id, floatingip): pass @abstractmethod
**** CubicPower OpenStack Study **** def get_floatingip(self, context, id, fields=None): pass @abstractmethod
**** CubicPower OpenStack Study **** def delete_floatingip(self, context, id): pass @abstractmethod
**** CubicPower OpenStack Study **** def get_floatingips(self, context, filters=None, fields=None, sorts=None, limit=None, marker=None, page_reverse=False): pass
**** CubicPower OpenStack Study **** def get_routers_count(self, context, filters=None): raise NotImplementedError()
**** CubicPower OpenStack Study **** def get_floatingips_count(self, context, filters=None): raise NotImplementedError()
|