summaryrefslogtreecommitdiffstats
path: root/nova/scheduler
diff options
context:
space:
mode:
authorSandy Walsh <sandy.walsh@rackspace.com>2011-03-21 07:49:58 -0700
committerSandy Walsh <sandy.walsh@rackspace.com>2011-03-21 07:49:58 -0700
commit8f0b60f598c28b2f558f3ecdaa2f9604926393e6 (patch)
tree55eed559dc31bdd7266bb017d5b1ded63bc01611 /nova/scheduler
parentabc6c82449dfc46a33dcd8190840e51f44b5b930 (diff)
remove scheduler.api.API. naming changes.
Diffstat (limited to 'nova/scheduler')
-rw-r--r--nova/scheduler/api.py43
1 files changed, 19 insertions, 24 deletions
diff --git a/nova/scheduler/api.py b/nova/scheduler/api.py
index b6d27dacc..e2cf3b6a3 100644
--- a/nova/scheduler/api.py
+++ b/nova/scheduler/api.py
@@ -40,30 +40,25 @@ def _call_scheduler(method, context, params=None):
return rpc.call(context, queue, kwargs)
-class API(object):
- """API for interacting with the scheduler."""
+def get_zone_list(context):
+ """Return a list of zones assoicated with this zone."""
+ items = _call_scheduler('get_zone_list', context)
+ for item in items:
+ item['api_url'] = item['api_url'].replace('\\/', '/')
+ return items
- @classmethod
- def get_zone_list(cls, context):
- """Return a list of zones assoicated with this zone."""
- items = _call_scheduler('get_zone_list', context)
- for item in items:
- item['api_url'] = item['api_url'].replace('\\/', '/')
- return items
- @classmethod
- def get_zone_capabilities(cls, context, service=None):
- """Returns a dict of key, value capabilities for this zone,
- or for a particular class of services running in this zone."""
- return _call_scheduler('get_zone_capabilities', context=context,
- params=dict(service=service))
+def get_zone_capabilities(context, service=None):
+ """Returns a dict of key, value capabilities for this zone,
+ or for a particular class of services running in this zone."""
+ return _call_scheduler('get_zone_capabilities', context=context,
+ params=dict(service=service))
- @classmethod
- def update_service_capabilities(cls, context, service_name, host,
- capabilities):
- """Send an update to all the scheduler services informing them
- of the capabilities of this service."""
- kwargs = dict(method='update_service_capabilities',
- args=dict(service_name=service_name, host=host,
- capabilities=capabilities))
- return rpc.fanout_cast(context, 'scheduler', kwargs)
+
+def update_service_capabilities(context, service_name, host, capabilities):
+ """Send an update to all the scheduler services informing them
+ of the capabilities of this service."""
+ kwargs = dict(method='update_service_capabilities',
+ args=dict(service_name=service_name, host=host,
+ capabilities=capabilities))
+ return rpc.fanout_cast(context, 'scheduler', kwargs)