¡@
OpenStack Study: kvs.py**** CubicPower OpenStack Study ****
# Copyright 2012 OpenStack Foundation # # 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 keystone import catalog from keystone.common import kvs from keystone import exception
**** CubicPower OpenStack Study **** class Catalog(kvs.Base, catalog.Driver): # Public interface
**** CubicPower OpenStack Study **** def get_catalog(self, user_id, tenant_id, metadata=None): return self.db.get('catalog-%s-%s' % (tenant_id, user_id)) # region crud
**** CubicPower OpenStack Study **** def _delete_child_regions(self, region_id): """Delete all child regions. Recursively delete any region that has the supplied region as its parent. """ children = [r for r in self.list_regions() if r['parent_region_id'] == region_id] for child in children: self._delete_child_regions(child['id']) self.delete_region(child['id'])
**** CubicPower OpenStack Study **** def _check_parent_region(self, region_ref): """Raise a NotFound if the parent region does not exist. If the region_ref has a specified parent_region_id, check that the parent exists, otherwise, raise a NotFound. """ parent_region_id = region_ref.get('parent_region_id') if parent_region_id is not None: # This will raise NotFound if the parent doesn't exist, # which is the behavior we want. self.get_region(parent_region_id)
**** CubicPower OpenStack Study **** def create_region(self, region): region_id = region['id'] region.setdefault('parent_region_id') self._check_parent_region(region) self.db.set('region-%s' % region_id, region) region_list = set(self.db.get('region_list', [])) region_list.add(region_id) self.db.set('region_list', list(region_list)) return region
**** CubicPower OpenStack Study **** def list_regions(self): return [self.get_region(x) for x in self.db.get('region_list', [])]
**** CubicPower OpenStack Study **** def get_region(self, region_id): return self.db.get('region-%s' % region_id)
**** CubicPower OpenStack Study **** def update_region(self, region_id, region): region.setdefault('parent_region_id') self._check_parent_region(region) self.db.set('region-%s' % region_id, region) return region
**** CubicPower OpenStack Study **** def delete_region(self, region_id): self._delete_child_regions(region_id) self.db.delete('region-%s' % region_id) region_list = set(self.db.get('region_list', [])) region_list.remove(region_id) self.db.set('region_list', list(region_list)) # service crud
**** CubicPower OpenStack Study **** def create_service(self, service_id, service): self.db.set('service-%s' % service_id, service) service_list = set(self.db.get('service_list', [])) service_list.add(service_id) self.db.set('service_list', list(service_list)) return service
**** CubicPower OpenStack Study **** def list_services(self, hints): return [self.get_service(x) for x in self.db.get('service_list', [])]
**** CubicPower OpenStack Study **** def get_service(self, service_id): return self.db.get('service-%s' % service_id)
**** CubicPower OpenStack Study **** def update_service(self, service_id, service): self.db.set('service-%s' % service_id, service) return service
**** CubicPower OpenStack Study **** def delete_service(self, service_id): # delete referencing endpoints for endpoint_id in self.db.get('endpoint_list', []): if self.get_endpoint(endpoint_id)['service_id'] == service_id: self.delete_endpoint(endpoint_id) self.db.delete('service-%s' % service_id) service_list = set(self.db.get('service_list', [])) service_list.remove(service_id) self.db.set('service_list', list(service_list)) # endpoint crud
**** CubicPower OpenStack Study **** def create_endpoint(self, endpoint_id, endpoint): self.get_service(endpoint['service_id']) self.db.set('endpoint-%s' % endpoint_id, endpoint) endpoint_list = set(self.db.get('endpoint_list', [])) endpoint_list.add(endpoint_id) self.db.set('endpoint_list', list(endpoint_list)) return endpoint
**** CubicPower OpenStack Study **** def list_endpoints(self, hints): return [self.get_endpoint(x) for x in self.db.get('endpoint_list', [])]
**** CubicPower OpenStack Study **** def get_endpoint(self, endpoint_id): return self.db.get('endpoint-%s' % endpoint_id)
**** CubicPower OpenStack Study **** def update_endpoint(self, endpoint_id, endpoint): self.db.set('endpoint-%s' % endpoint_id, endpoint) return endpoint
**** CubicPower OpenStack Study **** def delete_endpoint(self, endpoint_id): self.db.delete('endpoint-%s' % endpoint_id) endpoint_list = set(self.db.get('endpoint_list', [])) endpoint_list.remove(endpoint_id) self.db.set('endpoint_list', list(endpoint_list)) # Private interface
**** CubicPower OpenStack Study **** def _create_catalog(self, user_id, tenant_id, data): self.db.set('catalog-%s-%s' % (tenant_id, user_id), data) return data
**** CubicPower OpenStack Study **** def get_v3_catalog(self, user_id, tenant_id, metadata=None): raise exception.NotImplemented()
|