Basic Structure

.gitignore

@@ -0,0 +1 @@
+*.pyc

MANIFEST.in

@@ -0,0 +1 @@
+recursive-include public *

bugs/fixed_bugs.txt

@@ -0,0 +1,3 @@
+=================================================================
+Add fixed bugs in this file. Select a format to add bugs.
+=================================================================

bugs/implemented_blueprints.txt

@@ -0,0 +1,3 @@
+========================================================================
+Add already implemented. 
+========================================================================

bugs/known_bugs.txt

@@ -0,0 +1,3 @@
+=================================================================
+Add known bugs in this file. Select a format to add bugs.
+=================================================================

bugs/new_blueprints.txt

@@ -0,0 +1,3 @@
+========================================================================
+Add blueprints that needs to implmented.
+========================================================================

dockyard/api/app.py

@@ -0,0 +1,42 @@
+import pecan
+
+from dockyard.api import config as api_config
+from oslo_config import cfg
+from pecan import make_app
+
+from dockyard import model
+
+
+API_SERVICE_OPT = [
+    cfg.PortOpt('port',
+                 default=5869,
+                 help='Port for the dockyard service.'),
+    cfg.IPOpt('host',
+              default='127.0.0.1',
+              help='Listening address for dockyard service'),
+]
+
+CONF = cfg.CONF
+opt_group = cfg.OptGroup(name='default',
+                         title='Group for the default values for dockyard api')
+CONF.register_group(opt_group)
+CONF.register_opts(API_SERVICE_OPT, opt_group)
+
+def get_pecan_config():
+    # Set up the pecan configuration
+    filename = api_config.__file__.replace('.pyc', '.py')
+    return pecan.configuration.conf_from_file(filename)
+
+def setup_app(config=None):
+
+    if not config:
+        config = get_pecan_config() 
+
+    model.init_model()
+    app_conf = dict(config.app)
+
+    return make_app(
+        app_conf.pop('root'),
+        logging=getattr(config, 'logging', {}),
+        **app_conf
+    )

dockyard/api/config.py

@@ -0,0 +1,24 @@
+# Pecan Application Configurations
+app = {
+    'root': 'dockyard.controllers.root.RootController',
+    'modules': ['dockyard', 'dockyard.api'],
+    'static_root': '%(confdir)s/public',
+    'template_path': '%(confdir)s/dockyard/templates',
+    'debug': True,
+    'errors': {
+        404: '/error/404',
+        '__force_dict__': True
+    },
+   'acl_public_routes': [
+        '/',
+        '/v1',
+    ],
+
+}
+
+# Custom Configurations must be in Python dictionary format::
+#
+# foo = {'bar':'baz'}
+#
+# All configurations are accessible at::
+# pecan.conf

dockyard/cmd/api.py

@@ -0,0 +1,15 @@
+from wsgiref import simple_server
+
+from oslo_config import cfg
+from oslo_log import log as logging
+from dockyard.api import app as api_app
+
+def main():
+    app = api_app.setup_app()
+
+    # create the wsgi server and start it
+    host, port = cfg.CONF.default.host, cfg.CONF.default.port
+    srv = simple_server.make_server(host, port, app)
+    srv.serve_forever()
+
+main()

dockyard/common/base.py

@@ -0,0 +1,244 @@
+import sys
+import io
+import json
+
+from oslo_log import log as logging
+
+# python 2 and python 3 compatibility library
+from six import iteritems
+
+try:
+    import urllib3
+except ImportError:
+    raise ImportError('python client requires urllib3')
+
+try:
+    # for python3
+    from urllib.parse import urlencode
+except ImportError:
+    # for python2
+    from urllib import urlencode
+
+
+logger = logging.getLogger(__name__)
+
+
+class RESTResponse(io.IOBase):
+
+    def __init__(self, resp):
+        self.urllib3_response = resp
+        self.status = resp.status
+        self.reason = resp.reason
+        self.data = resp.data
+
+    def getheaders(self):
+        """
+        Returns a dictionary of the response headers.
+        """
+        return self.urllib3_response.getheaders()
+
+    def getheader(self, name, default=None):
+        """
+        Returns a given response header.
+        """
+        return self.urllib3_response.getheader(name, default)
+
+
+class RESTClientObject(object):
+
+    def __init__(self, pools_size=4):
+        # http pool manager
+        self.pool_manager = urllib3.PoolManager(
+            num_pools=pools_size
+        )
+
+    def agent(self, url):
+        """
+        Use `urllib3.util.parse_url` for backward compatibility.
+        Return proper pool manager for the http/https schemes.
+        """
+        url = urllib3.util.parse_url(url)
+        scheme = url.scheme
+        if scheme == 'https':
+            return self.ssl_pool_manager
+        else:
+            return self.pool_manager
+
+    def request(self, method, url, query_params=None, headers=None,
+                body=None, post_params=None):
+        """
+        :param method: http request method
+        :param url: http request url
+        :param query_params: query parameters in the url
+        :param headers: http request headers
+        :param body: request json body, for `application/json`
+        :param post_params: request post parameters,
+                            `application/x-www-form-urlencode`
+                            and `multipart/form-data`
+        """
+        method = method.upper()
+        assert method in ['GET', 'HEAD', 'DELETE', 'POST', 'PUT', 'PATCH']
+
+        if post_params and body:
+            raise ValueError(
+                "body parameter cannot be used with post_params parameter."
+            )
+
+        post_params = post_params or {}
+        headers = headers or {}
+
+        if 'Content-Type' not in headers:
+            headers['Content-Type'] = 'application/json'
+
+        # For `POST`, `PUT`, `PATCH`
+        if method in ['POST', 'PUT', 'PATCH']:
+            if query_params:
+                url += '?' + urlencode(query_params)
+            if headers['Content-Type'] == 'application/json':
+                response = self.agent(url).request(method, url,
+                                      body=json.dumps(body),
+                                        headers=headers)
+            if headers['Content-Type'] == 'application/x-www-form-urlencoded':
+                response = self.agent(url).request(method, url,
+                                        encode_multipart=False,
+                                        headers=headers)
+            if headers['Content-Type'] == 'multipart/form-data':
+                # must del headers['Content-Type'], or the correct Content-Type
+                # which generated by urllib3 will be overwritten.
+                del headers['Content-Type']
+                response = self.agent(url).request(method, url,
+                                        encode_multipart=True,
+                                        headers=headers)
+        # For `GET`, `HEAD`, `DELETE`
+        else:
+            response = self.agent(url).request(method, url,
+                                    headers=headers)
+        response = RESTResponse(response)
+
+        # In the python 3, the response.data is bytes.
+        # we need to decode it to string.
+        if sys.version_info > (3,):
+            response.data = response.data.decode('utf8')
+        # log response body
+        #logger.debug("response body: %s" % response.data)
+
+        if response.status not in range(200, 206):
+            raise ApiException(http_resp=response)
+
+        return response
+
+    def GET(self, url, headers=None, query_params=None):
+        return self.request("GET", url,
+                            headers=headers,
+                            query_params=query_params)
+
+    def HEAD(self, url, headers=None, query_params=None):
+        return self.request("HEAD", url,
+                            headers=headers,
+                            query_params=query_params)
+
+    def DELETE(self, url, headers=None, query_params=None):
+        return self.request("DELETE", url,
+                            headers=headers,
+                            query_params=query_params)
+
+    def POST(self, url, headers=None, query_params=None, post_params=None, body=None):
+        return self.request("POST", url,
+                            headers=headers,
+                            query_params=query_params,
+                            post_params=post_params,
+                            body=body)
+
+    def PUT(self, url, headers=None, query_params=None, post_params=None, body=None):
+        return self.request("PUT", url,
+                            headers=headers,
+                            query_params=query_params,
+                            post_params=post_params,
+                            body=body)
+
+    def PATCH(self, url, headers=None, query_params=None, post_params=None, body=None):
+        return self.request("PATCH", url,
+                            headers=headers,
+                            query_params=query_params,
+                            post_params=post_params,
+                            body=body)
+
+
+class ApiException(Exception):
+
+    def __init__(self, status=None, reason=None, http_resp=None):
+        if http_resp:
+            self.status = http_resp.status
+            self.reason = http_resp.reason
+            self.body = http_resp.data
+            self.headers = http_resp.getheaders()
+        else:
+            self.status = status
+            self.reason = reason
+            self.body = None
+            self.headers = None
+
+    def __str__(self):
+        """
+        Custom error messages for exception
+        """
+        error_message = "({0})\n"\
+                        "Reason: {1}\n".format(self.status, self.reason)
+        if self.headers:
+            error_message += "HTTP response headers: {0}\n".format(self.headers)
+
+        if self.body:
+            error_message += "HTTP response body: {0}\n".format(self.body)
+
+        return error_message
+
+class RESTClient(object):
+    """
+    A class with methods to perform JSON requests.
+    """
+
+    def __init__(self):
+        self.IMPL = RESTClientObject()
+
+    def request(self, *n, **kw):
+        """
+        Perform a REST request and parse the response.
+        """
+        return self.IMPL.request(*n, **kw)
+
+    def GET(self, *n, **kw):
+        """
+        Perform a GET request using `RESTClient.request()`.
+        """
+        return self.IMPL.GET(*n, **kw)
+
+    def HEAD(self, *n, **kw):
+        """
+        Perform a HEAD request using `RESTClient.request()`.
+        """
+        return self.IMPL.GET(*n, **kw)
+
+    def POST(self, *n, **kw):
+        """
+        Perform a POST request using `RESTClient.request()`
+        """
+        return self.IMPL.POST(*n, **kw)
+
+    def PUT(self, *n, **kw):
+        """
+        Perform a PUT request using `RESTClient.request()`
+        """
+        return self.IMPL.PUT(*n, **kw)
+
+    def PATCH(self, *n, **kw):
+        """
+        Perform a PATCH request using `RESTClient.request()`
+        """
+        return self.IMPL.PATCH(*n, **kw)
+
+    def DELETE(self, *n, **kw):
+        """
+        Perform a DELETE request using `RESTClient.request()`
+        """
+        return self.IMPL.DELETE(*n, **kw)
+

dockyard/common/cluster/cluster.py

@@ -0,0 +1,14 @@
+from oslo_config import cfg
+
+class Cluster(object):
+    def __init__(self):
+        pass
+
+    def register(self, cluster_id, host_ip, port):
+        pass
+
+    def unregister(self, cluster_id, host_ip):
+        pass 
+
+    def get_hosts(self):
+        return cfg.CONF.membership.hosts