¡@
OpenStack Study: rpcapi.py**** CubicPower OpenStack Study ****
# Copyright 2012, Red Hat, Inc. # # 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. """ Client side of the scheduler manager RPC API. """ from oslo.config import cfg from oslo import messaging from cinder.openstack.common import jsonutils from cinder import rpc CONF = cfg.CONF
**** CubicPower OpenStack Study **** class SchedulerAPI(object): '''Client side of the scheduler rpc API. API version history: 1.0 - Initial version. 1.1 - Add create_volume() method 1.2 - Add request_spec, filter_properties arguments to create_volume() 1.3 - Add migrate_volume_to_host() method 1.4 - Add retype method 1.5 - Add manage_existing method ''' RPC_API_VERSION = '1.0'
**** CubicPower OpenStack Study **** def __init__(self): super(SchedulerAPI, self).__init__() target = messaging.Target(topic=CONF.scheduler_topic, version=self.RPC_API_VERSION) self.client = rpc.get_client(target, version_cap='1.5')
**** CubicPower OpenStack Study **** def create_volume(self, ctxt, topic, volume_id, snapshot_id=None, image_id=None, request_spec=None, filter_properties=None): cctxt = self.client.prepare(version='1.2') request_spec_p = jsonutils.to_primitive(request_spec) return cctxt.cast(ctxt, 'create_volume', topic=topic, volume_id=volume_id, snapshot_id=snapshot_id, image_id=image_id, request_spec=request_spec_p, filter_properties=filter_properties)
**** CubicPower OpenStack Study **** def migrate_volume_to_host(self, ctxt, topic, volume_id, host, force_host_copy=False, request_spec=None, filter_properties=None): cctxt = self.client.prepare(version='1.3') request_spec_p = jsonutils.to_primitive(request_spec) return cctxt.cast(ctxt, 'migrate_volume_to_host', topic=topic, volume_id=volume_id, host=host, force_host_copy=force_host_copy, request_spec=request_spec_p, filter_properties=filter_properties)
**** CubicPower OpenStack Study **** def retype(self, ctxt, topic, volume_id, request_spec=None, filter_properties=None): cctxt = self.client.prepare(version='1.4') request_spec_p = jsonutils.to_primitive(request_spec) return cctxt.cast(ctxt, 'retype', topic=topic, volume_id=volume_id, request_spec=request_spec_p, filter_properties=filter_properties)
**** CubicPower OpenStack Study **** def manage_existing(self, ctxt, topic, volume_id, request_spec=None, filter_properties=None): cctxt = self.client.prepare(version='1.5') request_spec_p = jsonutils.to_primitive(request_spec) return cctxt.cast(ctxt, 'manage_existing', topic=topic, volume_id=volume_id, request_spec=request_spec_p, filter_properties=filter_properties)
**** CubicPower OpenStack Study **** def update_service_capabilities(self, ctxt, service_name, host, capabilities): # FIXME(flaper87): What to do with fanout? cctxt = self.client.prepare(fanout=True) cctxt.cast(ctxt, 'update_service_capabilities', service_name=service_name, host=host, capabilities=capabilities)
|