FIX-1236 Adds config list in rpc

Change-Id: Ia78893d93209ee7ec68d49ffa062aff649e486e5
This commit is contained in:
Kanagaraj Manickam 2016-03-22 05:54:13 +05:30
parent e4a0ceb25d
commit c17ee850d2
4 changed files with 48 additions and 9 deletions

View File

@ -106,6 +106,16 @@ class ConductorManager(object):
def infra_perspective_get(self, context):
return db_api.infra_perspective_get(context)
@request_context
def config_get_by_name_for_service_worker(self,
context,
service_worker_id,
name=None,
only_configured=True):
return db_api.config_get_by_name_for_service_worker(context,
service_worker_id,
name,
only_configured)
class ServiceProcessor(object):
def __init__(self, registration_info):

View File

@ -96,6 +96,18 @@ class ConductorAPI(object):
return self.client.call(context,
'infra_perspective_get')
@wrapper_function
def config_get_by_name_for_service_worker(self,
context,
service_worker_id,
name=None,
only_configured=True):
return self.client.call(context,
'config_get_by_name_for_service_worker',
service_worker_id=service_worker_id,
name=name,
only_configured=only_configured)
if __name__ == '__main__':
# from namos.common import config
@ -105,10 +117,21 @@ if __name__ == '__main__':
from oslo_context import context
c = ConductorAPI()
# c.add_region(context.RequestContext(),
# {'name': 'RegionOne11',
# 'keystone_region_id': 'region_one',
# 'extra': {'location': 'bangalore'},
# 'id': 'd7dcd175-27ef-46b5-997f-e6e572f320af'})
print (json.dumps(c.infra_perspective_get(context.RequestContext())))
def add_sample_region():
c.add_region(context.RequestContext(),
{'name': 'RegionOne11',
'keystone_region_id': 'region_one',
'extra': {'location': 'bangalore'},
'id': 'd7dcd175-27ef-46b5-997f-e6e572f320af'})
def print_infra():
print (json.dumps(c.infra_perspective_get(context.RequestContext())))
def print_sample_conf():
for cf in c.config_get_by_name_for_service_worker(
context.RequestContext(),
service_worker_id='fc88fd41-7e9c-42c9-891d-3823efd4824e'):
print ('%s %s' % (cf['name'], cf['value']))
print_sample_conf()

View File

@ -328,10 +328,12 @@ def config_get_by_name(context, name):
def config_get_by_name_for_service_worker(context,
service_worker_id,
name=None):
name=None,
only_configured=True):
return IMPL.config_get_by_name_for_service_worker(context,
service_worker_id,
name)
name,
only_configured)
def config_get_all(context):

View File

@ -519,11 +519,15 @@ def config_get_by_name(context, name):
def config_get_by_name_for_service_worker(context,
service_worker_id,
name=None):
name=None,
only_configured=True):
query = _model_query(context, models.OsloConfig). \
filter_by(service_worker_id=service_worker_id)
if name is not None:
query = query.filter_by(name=name)
elif only_configured:
query = query.filter(
models.OsloConfig.value != models.OsloConfig.default_value)
return query.all()