Merge "Agent Stubs"

cyborg/agent/__init__.py

@@ -0,0 +1,19 @@
+# -*- coding: utf-8 -*-
+
+# 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.
+
+import pbr.version
+
+
+__version__ = pbr.version.VersionInfo(
+    'cyborg-agent').version_string()

cyborg/agent/agent.conf

@@ -0,0 +1,3 @@
+[DEFAULT]
+transport_url=
+server_id=

cyborg/agent/agent.py

@@ -0,0 +1,61 @@
+# -*- coding: utf-8 -*-
+
+#
+# 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.
+
+import conf
+import eventlet
+from oslo_config import cfg
+from oslo_log import log as logging
+import oslo_messaging as messaging
+import rpcapi
+import time
+
+eventlet.monkey_patch()
+
+CONF = cfg.CONF
+
+conf.register_opts(CONF)
+
+LOG = logging.getLogger(__name__)
+logging.register_options(CONF)
+logging.setup(CONF, 'Cyborg.Agent')
+
+url = messaging.TransportURL.parse(CONF, url=CONF.transport_url)
+transport = messaging.get_notification_transport(CONF, url)
+
+notifier = messaging.Notifier(transport,
+                              driver='messaging',
+                              publisher_id='Cyborg.Agent',
+                              topic='info')
+
+rpc_targets = messaging.Target(topic='cyborg_control', server=CONF.server_id)
+rpc_endpoints = [
+    rpcapi.RPCEndpoint()
+]
+access_policy = messaging.ExplicitRPCAccessPolicy
+rpc_server = messaging.get_rpc_server(transport,
+                                      rpc_targets,
+                                      rpc_endpoints,
+                                      executor='eventlet',
+                                      access_policy=access_policy)
+
+try:
+    print("Cyborg Agent running")
+    rpc_server.start()
+    while True:
+        time.sleep(1)
+except KeyboardInterrupt:
+    print("Stopping server")
+    rpc_server.stop()
+    rpc_server.wait()

cyborg/agent/conf.py

@@ -0,0 +1,28 @@
+#
+#    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 oslo_config import cfg
+import uuid
+
+default_opts = [
+    cfg.StrOpt('transport_url',
+               default='',
+               help='Transport url to use for messaging'),
+    cfg.StrOpt('server_id',
+               default=uuid.uuid4(),
+               help='Unique identifier for this agent'),
+]
+
+
+def register_opts(conf):
+    conf.register_opts(default_opts)

cyborg/agent/rpcapi.py

@@ -0,0 +1,30 @@
+# -*- coding: utf-8 -*-
+
+#
+# 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.
+
+
+class RPCEndpoint(object):
+
+    # Conductor functions exposed for external calls
+    def __init__(self):
+        pass
+
+    def list_accelerators(self, ctxt):
+        pass
+
+    def update_accelerator(self, ctxt, accelerator):
+        pass
+
+    def discover_accelerators(self, ctxt):
+        pass