initial manager commit

manager/manager.py

+#!/usr/bin/env python
+
+from mancelery import celery
+
+
+@celery.task
+def create_vm():
+    '''Create new virtual machine from VM class.
+    '''
+    # Get info from scheduler (free sapce, node with enough cpu and ram)
+
+    # Create hard drives (storage)
+
+    # Create machine (vmdriver)
+    # Estabilish network connection (vmdriver)
+    # Resume machine (vmdriver)
+    pass
+
+
+def delete():
+    pass
+
+
+def save_as():
+    pass
+
+
+def suspend():
+    pass
+
+
+def resume():
+    pass
+
+
+def restart():
+    pass
+
+
+def reset():
+    pass

manager/mancelery.py

+#!/usr/bin/env python
+
+from celery import Celery
+from kombu import Queue, Exchange
+from socket import gethostname
+
+
+HOSTNAME = gethostname()
+
+celery = Celery('manager', backend='amqp',
+                broker='amqp://cloud:test@10.9.1.31/vmdriver',
+                include=['vmdriver_stub'])
+
+celery.conf.update(
+    CELERY_QUEUES=(
+        Queue(HOSTNAME + '.man', Exchange(
+            'manager', type='direct'), routing_key="manager"),
+    )
+)

manager/vmdriver_stub.py

+#!/usr/bin/env pyhon
+
+
+#Stubs for vmdriver