1
# Copyright 2012 IBM Corp.
3
# Licensed under the Apache License, Version 2.0 (the "License"); you may
4
# not use this file except in compliance with the License. You may obtain
5
# a copy of the License at
7
# http://www.apache.org/licenses/LICENSE-2.0
9
# Unless required by applicable law or agreed to in writing, software
10
# distributed under the License is distributed on an "AS IS" BASIS, WITHOUT
11
# WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. See the
12
# License for the specific language governing permissions and limitations
15
"""Handles all requests to the conductor service"""
17
from nova.conductor import manager
18
from nova.conductor import rpcapi
19
from nova.openstack.common import cfg
22
cfg.BoolOpt('use_local',
24
help='Perform nova-conductor operations locally'),
27
help='the topic conductor nodes listen on'),
29
default='nova.conductor.manager.ConductorManager',
30
help='full class name for the Manager for conductor'),
32
conductor_group = cfg.OptGroup(name='conductor',
33
title='Conductor Options')
35
CONF.register_group(conductor_group)
36
CONF.register_opts(conductor_opts, conductor_group)
39
class LocalAPI(object):
40
"""A local version of the conductor API that does database updates
41
locally instead of via RPC"""
44
self._manager = manager.ConductorManager()
46
def instance_update(self, context, instance_uuid, **updates):
47
"""Perform an instance update in the database"""
48
return self._manager.instance_update(context, instance_uuid, updates)
52
"""Conductor API that does updates via RPC to the ConductorManager"""
55
self.conductor_rpcapi = rpcapi.ConductorAPI()
57
def instance_update(self, context, instance_uuid, **updates):
58
"""Perform an instance update in the database"""
59
return self.conductor_rpcapi.instance_update(context, instance_uuid,