cloudstack-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From tall...@apache.org
Subject [28/29] CLOUSTACK-5099: Utils.py-has-wrong-reference, cleaned it. As well added Uniform naming convention Signed-off-by: SrikanteswaraRao Talluri <talluri@apache.org>
Date Fri, 08 Nov 2013 10:34:15 GMT
http://git-wip-us.apache.org/repos/asf/cloudstack/blob/ec00a6fb/test/integration/smoke/test_network.py
----------------------------------------------------------------------
diff --git a/test/integration/smoke/test_network.py b/test/integration/smoke/test_network.py
index f204595..09d6437 100644
--- a/test/integration/smoke/test_network.py
+++ b/test/integration/smoke/test_network.py
@@ -21,7 +21,7 @@ import marvin
 from marvin.cloudstackException import cloudstackAPIException
 from marvin.cloudstackTestCase import *
 from marvin.cloudstackAPI import *
-from marvin import remoteSSHClient
+from marvin.sshClient import SshClient
 from marvin.integration.lib.utils import *
 from marvin.integration.lib.base import *
 from marvin.integration.lib.common import *
@@ -460,7 +460,7 @@ class TestPortForwarding(cloudstackTestCase):
                 "SSHing into VM with IP address %s after NAT rule deletion" %
                                                  self.virtual_machine.ipaddress)
 
-            remoteSSHClient(
+           SshClient(
                                             src_nat_ip_addr.ipaddress,
                                             self.virtual_machine.ssh_port,
                                             self.virtual_machine.username,
@@ -578,7 +578,7 @@ class TestPortForwarding(cloudstackTestCase):
                 "SSHing into VM with IP address %s after NAT rule deletion" %
                                                  self.virtual_machine.ipaddress)
 
-            remoteSSHClient(
+           SshClient(
                                             ip_address.ipaddress.ipaddress,
                                             self.virtual_machine.ssh_port,
                                             self.virtual_machine.username,
@@ -741,7 +741,7 @@ class TestRebootRouter(cloudstackTestCase):
         try:
             self.debug("SSH into VM (ID : %s ) after reboot" % self.vm_1.id)
 
-            remoteSSHClient(
+           SshClient(
                                     self.public_ip.ipaddress.ipaddress,
                                     self.services["natrule"]["publicport"],
                                     self.vm_1.username,
@@ -883,7 +883,7 @@ class TestReleaseIP(cloudstackTestCase):
 
         # SSH Attempt though public IP should fail
         with self.assertRaises(Exception):
-            ssh_2 = remoteSSHClient(
+            ssh_2 = SshClient(
                                     self.ip_addr.ipaddress,
                                     self.services["natrule"]["publicport"],
                                     self.virtual_machine.username,

http://git-wip-us.apache.org/repos/asf/cloudstack/blob/ec00a6fb/test/integration/smoke/test_nic.py
----------------------------------------------------------------------
diff --git a/test/integration/smoke/test_nic.py b/test/integration/smoke/test_nic.py
index 583fc29..ac95685 100644
--- a/test/integration/smoke/test_nic.py
+++ b/test/integration/smoke/test_nic.py
@@ -18,7 +18,7 @@
 import marvin
 from marvin.cloudstackTestCase import *
 from marvin.cloudstackAPI import *
-from marvin.remoteSSHClient import remoteSSHClient
+from marvin.sshClient import SshClient
 from marvin.integration.lib.utils import *
 from marvin.integration.lib.base import *
 from marvin.integration.lib.common import *

http://git-wip-us.apache.org/repos/asf/cloudstack/blob/ec00a6fb/test/integration/smoke/test_pvlan.py
----------------------------------------------------------------------
diff --git a/test/integration/smoke/test_pvlan.py b/test/integration/smoke/test_pvlan.py
index 0a427ba..aeb47f9 100644
--- a/test/integration/smoke/test_pvlan.py
+++ b/test/integration/smoke/test_pvlan.py
@@ -20,7 +20,7 @@
 import marvin
 from marvin.cloudstackTestCase import *
 from marvin.cloudstackAPI import *
-from marvin import remoteSSHClient
+from marvin.sshClient import SshClient
 from marvin.integration.lib.utils import *
 from marvin.integration.lib.base import *
 from marvin.integration.lib.common import *

http://git-wip-us.apache.org/repos/asf/cloudstack/blob/ec00a6fb/test/integration/smoke/test_resource_detail.py
----------------------------------------------------------------------
diff --git a/test/integration/smoke/test_resource_detail.py b/test/integration/smoke/test_resource_detail.py
index 93bc2ff..00a7b5c 100644
--- a/test/integration/smoke/test_resource_detail.py
+++ b/test/integration/smoke/test_resource_detail.py
@@ -20,7 +20,7 @@
 import marvin
 from marvin.cloudstackTestCase import *
 from marvin.cloudstackAPI import *
-from marvin.remoteSSHClient import remoteSSHClient
+from marvin.sshClient import SshClient
 from marvin.integration.lib.utils import *
 from marvin.integration.lib.base import *
 from marvin.integration.lib.common import *

http://git-wip-us.apache.org/repos/asf/cloudstack/blob/ec00a6fb/test/integration/smoke/test_routers.py
----------------------------------------------------------------------
diff --git a/test/integration/smoke/test_routers.py b/test/integration/smoke/test_routers.py
index 0f32e27..7d32413 100644
--- a/test/integration/smoke/test_routers.py
+++ b/test/integration/smoke/test_routers.py
@@ -20,7 +20,7 @@
 import marvin
 from marvin.cloudstackTestCase import *
 from marvin.cloudstackAPI import *
-from marvin import remoteSSHClient
+from marvin.sshClient import SshClient
 from marvin.integration.lib.utils import *
 from marvin.integration.lib.base import *
 from marvin.integration.lib.common import *

http://git-wip-us.apache.org/repos/asf/cloudstack/blob/ec00a6fb/test/integration/smoke/test_ssvm.py
----------------------------------------------------------------------
diff --git a/test/integration/smoke/test_ssvm.py b/test/integration/smoke/test_ssvm.py
index 9fa59a9..a2b9eab 100644
--- a/test/integration/smoke/test_ssvm.py
+++ b/test/integration/smoke/test_ssvm.py
@@ -20,7 +20,7 @@
 import marvin
 from marvin.cloudstackTestCase import *
 from marvin.cloudstackAPI import *
-from marvin import remoteSSHClient
+from marvin.sshClient import SshClient
 from marvin.integration.lib.utils import *
 from marvin.integration.lib.base import *
 from marvin.integration.lib.common import *

http://git-wip-us.apache.org/repos/asf/cloudstack/blob/ec00a6fb/test/integration/smoke/test_templates.py
----------------------------------------------------------------------
diff --git a/test/integration/smoke/test_templates.py b/test/integration/smoke/test_templates.py
index 9478440..e371ad4 100644
--- a/test/integration/smoke/test_templates.py
+++ b/test/integration/smoke/test_templates.py
@@ -20,7 +20,7 @@
 import marvin
 from marvin.cloudstackTestCase import *
 from marvin.cloudstackAPI import *
-from marvin.remoteSSHClient import remoteSSHClient
+from marvin.sshClient import SshClient
 from marvin.integration.lib.utils import *
 from marvin.integration.lib.base import *
 from marvin.integration.lib.common import *

http://git-wip-us.apache.org/repos/asf/cloudstack/blob/ec00a6fb/test/integration/smoke/test_volumes.py
----------------------------------------------------------------------
diff --git a/test/integration/smoke/test_volumes.py b/test/integration/smoke/test_volumes.py
index b60b70e..816ae03 100644
--- a/test/integration/smoke/test_volumes.py
+++ b/test/integration/smoke/test_volumes.py
@@ -21,7 +21,7 @@ import marvin
 from marvin.cloudstackTestCase import *
 from marvin.cloudstackException import *
 from marvin.cloudstackAPI import *
-from marvin.remoteSSHClient import remoteSSHClient
+from marvin.sshClient import SshClient
 from marvin.integration.lib.utils import *
 from marvin.integration.lib.base import *
 from marvin.integration.lib.common import *

http://git-wip-us.apache.org/repos/asf/cloudstack/blob/ec00a6fb/tools/marvin/build/lib/marvin/TestCaseExecuteEngine.py
----------------------------------------------------------------------
diff --git a/tools/marvin/build/lib/marvin/TestCaseExecuteEngine.py b/tools/marvin/build/lib/marvin/TestCaseExecuteEngine.py
new file mode 100644
index 0000000..f5af1fe
--- /dev/null
+++ b/tools/marvin/build/lib/marvin/TestCaseExecuteEngine.py
@@ -0,0 +1,102 @@
+# Licensed to the Apache Software Foundation (ASF) under one
+# or more contributor license agreements.  See the NOTICE file
+# distributed with this work for additional information
+# regarding copyright ownership.  The ASF licenses this file
+# to you 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 unittest
+import os
+import sys
+import logging
+from functools import partial
+
+
+def testCaseLogger(message, logger=None):
+    if logger is not None:
+        logger.debug(message)
+
+
+class TestCaseExecuteEngine(object):
+    def __init__(self, testclient, config, testcaseLogFile=None,
+                 testResultLogFile=None):
+        """
+        Initialize the testcase execution engine, just the basics here
+        @var testcaseLogFile: client log file
+        @var testResultLogFile: summary report file
+        """
+        self.testclient = testclient
+        self.config = config
+        self.logformat =\
+            logging.Formatter(
+                "%(asctime)s - %(levelname)s - %(name)s - %(message)s")
+        self.loader = unittest.loader.TestLoader()
+        self.suite = None
+
+        if testcaseLogFile is not None:
+            self.logfile = testcaseLogFile
+            self.logger = logging.getLogger("TestCaseExecuteEngine")
+            fh = logging.FileHandler(self.logfile)
+            fh.setFormatter(self.logformat)
+            self.logger.addHandler(fh)
+            self.logger.setLevel(logging.DEBUG)
+        if testResultLogFile is not None:
+            ch = logging.StreamHandler()
+            ch.setLevel(logging.ERROR)
+            ch.setFormatter(self.logformat)
+            self.logger.addHandler(ch)
+            fp = open(testResultLogFile, "w")
+            self.testResultLogFile = fp
+        else:
+            self.testResultLogFile = sys.stdout
+
+    def loadTestsFromDir(self, testDirectory):
+        """ Load the test suites from a package with multiple test files """
+        self.suite = self.loader.discover(testDirectory)
+        self.injectTestCase(self.suite)
+
+    def loadTestsFromFile(self, file_name):
+        """ Load the tests from a single script/module """
+        if os.path.isfile(file_name):
+            self.suite = self.loader.discover(os.path.dirname(file_name),
+                                              os.path.basename(file_name))
+            self.injectTestCase(self.suite)
+
+    def injectTestCase(self, testSuites):
+        for test in testSuites:
+            if isinstance(test, unittest.BaseTestSuite):
+                self.injectTestCase(test)
+            else:
+                #logger bears the name of the test class
+                testcaselogger = logging.getLogger("%s" % (test))
+                fh = logging.FileHandler(self.logfile)
+                fh.setFormatter(self.logformat)
+                testcaselogger.addHandler(fh)
+                testcaselogger.setLevel(logging.DEBUG)
+
+                #inject testclient and logger into each unittest
+                setattr(test, "testClient", self.testclient)
+                setattr(test, "config", self.config)
+                setattr(test, "debug", partial(testCaseLogger,
+                                               logger=testcaselogger))
+                setattr(test.__class__, "clstestclient", self.testclient)
+                if hasattr(test, "user"):
+                    # attribute when test is entirely executed as user
+                    self.testclient.createUserApiClient(test.UserName,
+                                                        test.DomainName,
+                                                        test.AcctType)
+
+    def run(self):
+        if self.suite:
+            unittest.TextTestRunner(stream=self.testResultLogFile,
+                                    verbosity=2).run(self.suite)

http://git-wip-us.apache.org/repos/asf/cloudstack/blob/ec00a6fb/tools/marvin/build/lib/marvin/__init__.py
----------------------------------------------------------------------
diff --git a/tools/marvin/build/lib/marvin/__init__.py b/tools/marvin/build/lib/marvin/__init__.py
new file mode 100644
index 0000000..7af168e
--- /dev/null
+++ b/tools/marvin/build/lib/marvin/__init__.py
@@ -0,0 +1,18 @@
+# Licensed to the Apache Software Foundation (ASF) under one
+# or more contributor license agreements.  See the NOTICE file
+# distributed with this work for additional information
+# regarding copyright ownership.  The ASF licenses this file
+# to you 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.
+
+#Marvin - The cloudstack test client

http://git-wip-us.apache.org/repos/asf/cloudstack/blob/ec00a6fb/tools/marvin/build/lib/marvin/asyncJobMgr.py
----------------------------------------------------------------------
diff --git a/tools/marvin/build/lib/marvin/asyncJobMgr.py b/tools/marvin/build/lib/marvin/asyncJobMgr.py
new file mode 100644
index 0000000..25818a6
--- /dev/null
+++ b/tools/marvin/build/lib/marvin/asyncJobMgr.py
@@ -0,0 +1,261 @@
+# Licensed to the Apache Software Foundation (ASF) under one
+# or more contributor license agreements.  See the NOTICE file
+# distributed with this work for additional information
+# regarding copyright ownership.  The ASF licenses this file
+# to you 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 threading
+import cloudstackException
+import time
+import Queue
+import copy
+import sys
+import jsonHelper
+import datetime
+
+
+class job(object):
+    def __init__(self):
+        self.id = None
+        self.cmd = None
+
+
+class jobStatus(object):
+    def __init__(self):
+        self.result = None
+        self.status = None
+        self.startTime = None
+        self.endTime = None
+        self.duration = None
+        self.jobId = None
+        self.responsecls = None
+
+    def __str__(self):
+        return '{%s}' % str(', '.join('%s : %s' % (k, repr(v)) for (k, v)
+                                      in self.__dict__.iteritems()))
+
+
+class workThread(threading.Thread):
+    def __init__(self, in_queue, outqueue, apiClient, db=None, lock=None):
+        threading.Thread.__init__(self)
+        self.inqueue = in_queue
+        self.output = outqueue
+        self.connection = apiClient.connection.__copy__()
+        self.db = None
+        self.lock = lock
+
+    def queryAsynJob(self, job):
+        if job.jobId is None:
+            return job
+
+        try:
+            self.lock.acquire()
+            result = self.connection.poll(job.jobId, job.responsecls).jobresult
+        except cloudstackException.cloudstackAPIException, e:
+            result = str(e)
+        finally:
+            self.lock.release()
+
+        job.result = result
+        return job
+
+    def executeCmd(self, job):
+        cmd = job.cmd
+
+        jobstatus = jobStatus()
+        jobId = None
+        try:
+            self.lock.acquire()
+
+            if cmd.isAsync == "false":
+                jobstatus.startTime = datetime.datetime.now()
+
+                result = self.connection.make_request(cmd)
+                jobstatus.result = result
+                jobstatus.endTime = datetime.datetime.now()
+                jobstatus.duration =\
+                    time.mktime(jobstatus.endTime.timetuple()) - time.mktime(
+                        jobstatus.startTime.timetuple())
+            else:
+                result = self.connection.make_request(cmd, None, True)
+                if result is None:
+                    jobstatus.status = False
+                else:
+                    jobId = result.jobid
+                    jobstatus.jobId = jobId
+                    try:
+                        responseName =\
+                            cmd.__class__.__name__.replace("Cmd", "Response")
+                        jobstatus.responsecls =\
+                            jsonHelper.getclassFromName(cmd, responseName)
+                    except:
+                        pass
+                    jobstatus.status = True
+        except cloudstackException.cloudstackAPIException, e:
+            jobstatus.result = str(e)
+            jobstatus.status = False
+        except:
+            jobstatus.status = False
+            jobstatus.result = sys.exc_info()
+        finally:
+            self.lock.release()
+
+        return jobstatus
+
+    def run(self):
+        while self.inqueue.qsize() > 0:
+            job = self.inqueue.get()
+            if isinstance(job, jobStatus):
+                jobstatus = self.queryAsynJob(job)
+            else:
+                jobstatus = self.executeCmd(job)
+
+            self.output.put(jobstatus)
+            self.inqueue.task_done()
+
+        '''release the resource'''
+        self.connection.close()
+
+
+class jobThread(threading.Thread):
+    def __init__(self, inqueue, interval):
+        threading.Thread.__init__(self)
+        self.inqueue = inqueue
+        self.interval = interval
+
+    def run(self):
+        while self.inqueue.qsize() > 0:
+            job = self.inqueue.get()
+            try:
+                job.run()
+                '''release the api connection'''
+                job.apiClient.connection.close()
+            except:
+                pass
+
+            self.inqueue.task_done()
+            time.sleep(self.interval)
+
+
+class outputDict(object):
+    def __init__(self):
+        self.lock = threading.Condition()
+        self.dict = {}
+
+
+class asyncJobMgr(object):
+    def __init__(self, apiClient, db):
+        self.inqueue = Queue.Queue()
+        self.output = outputDict()
+        self.outqueue = Queue.Queue()
+        self.apiClient = apiClient
+        self.db = db
+
+    def submitCmds(self, cmds):
+        if not self.inqueue.empty():
+            return False
+        id = 0
+        ids = []
+        for cmd in cmds:
+            asyncjob = job()
+            asyncjob.id = id
+            asyncjob.cmd = cmd
+            self.inqueue.put(asyncjob)
+            id += 1
+            ids.append(id)
+        return ids
+
+    def updateTimeStamp(self, jobstatus):
+        jobId = jobstatus.jobId
+        if jobId is not None and self.db is not None:
+            result = self.db.execute(
+                "select job_status, created, last_updated from async_job where\
+ id='%s'" % str(jobId))
+            if result is not None and len(result) > 0:
+                if result[0][0] == 1:
+                    jobstatus.status = True
+                else:
+                    jobstatus.status = False
+                    jobstatus.startTime = result[0][1]
+                    jobstatus.endTime = result[0][2]
+                    delta = jobstatus.endTime - jobstatus.startTime
+                    jobstatus.duration = delta.total_seconds()
+
+    def waitForComplete(self, workers=10):
+        self.inqueue.join()
+        lock = threading.Lock()
+        resultQueue = Queue.Queue()
+        '''intermediate result is stored in self.outqueue'''
+        for i in range(workers):
+            worker = workThread(self.outqueue, resultQueue, self.apiClient,
+                                self.db, lock)
+            worker.start()
+
+        self.outqueue.join()
+
+        asyncJobResult = []
+        while resultQueue.qsize() > 0:
+            jobstatus = resultQueue.get()
+            self.updateTimeStamp(jobstatus)
+            asyncJobResult.append(jobstatus)
+
+        return asyncJobResult
+
+    def submitCmdsAndWait(self, cmds, workers=10):
+        '''
+            put commands into a queue at first, then start workers numbers
+            threads to execute this commands
+        '''
+        self.submitCmds(cmds)
+        lock = threading.Lock()
+        for i in range(workers):
+            worker = workThread(self.inqueue, self.outqueue, self.apiClient,
+                                self.db, lock)
+            worker.start()
+
+        return self.waitForComplete(workers)
+
+    def submitJobExecuteNtimes(self, job, ntimes=1, nums_threads=1,
+                               interval=1):
+        '''
+        submit one job and execute the same job ntimes, with nums_threads
+        of threads
+        '''
+        inqueue1 = Queue.Queue()
+        lock = threading.Condition()
+        for i in range(ntimes):
+            newjob = copy.copy(job)
+            setattr(newjob, "apiClient", copy.copy(self.apiClient))
+            setattr(newjob, "lock", lock)
+            inqueue1.put(newjob)
+
+        for i in range(nums_threads):
+            work = jobThread(inqueue1, interval)
+            work.start()
+        inqueue1.join()
+
+    def submitJobs(self, jobs, nums_threads=1, interval=1):
+        '''submit n jobs, execute them with nums_threads of threads'''
+        inqueue1 = Queue.Queue()
+        lock = threading.Condition()
+
+        for job in jobs:
+            setattr(job, "apiClient", copy.copy(self.apiClient))
+            setattr(job, "lock", lock)
+            inqueue1.put(job)
+
+        for i in range(nums_threads):
+            work = jobThread(inqueue1, interval)
+            work.start()
+        inqueue1.join()

http://git-wip-us.apache.org/repos/asf/cloudstack/blob/ec00a6fb/tools/marvin/build/lib/marvin/cloudstackAPI/__init__.py
----------------------------------------------------------------------
diff --git a/tools/marvin/build/lib/marvin/cloudstackAPI/__init__.py b/tools/marvin/build/lib/marvin/cloudstackAPI/__init__.py
new file mode 100644
index 0000000..ad0c1e5
--- /dev/null
+++ b/tools/marvin/build/lib/marvin/cloudstackAPI/__init__.py
@@ -0,0 +1,18 @@
+# Licensed to the Apache Software Foundation (ASF) under one
+# or more contributor license agreements.  See the NOTICE file
+# distributed with this work for additional information
+# regarding copyright ownership.  The ASF licenses this file
+# to you 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.
+
+__all__ = ["createAccount","deleteAccount","updateAccount","disableAccount","enableAccount","lockAccount","listAccounts","markDefaultZoneForAccount","createUser","deleteUser","updateUser","listUsers","lockUser","disableUser","enableUser","getUser","createDomain","updateDomain","deleteDomain","listDomains","listDomainChildren","getCloudIdentifier","updateResourceLimit","updateResourceCount","listResourceLimits","deployVirtualMachine","destroyVirtualMachine","rebootVirtualMachine","startVirtualMachine","stopVirtualMachine","resetPasswordForVirtualMachine","resetSSHKeyForVirtualMachine","updateVirtualMachine","listVirtualMachines","getVMPassword","restoreVirtualMachine","changeServiceForVirtualMachine","scaleVirtualMachine","assignVirtualMachine","migrateVirtualMachine","migrateVirtualMachineWithVolume","recoverVirtualMachine","createSnapshot","listSnapshots","deleteSnapshot","createSnapshotPolicy","deleteSnapshotPolicies","listSnapshotPolicies","revertSnapshot","createTemplate","regis
 terTemplate","updateTemplate","copyTemplate","deleteTemplate","listTemplates","updateTemplatePermissions","listTemplatePermissions","extractTemplate","prepareTemplate","attachIso","detachIso","listIsos","registerIso","updateIso","deleteIso","copyIso","updateIsoPermissions","listIsoPermissions","extractIso","listOsTypes","listOsCategories","createServiceOffering","deleteServiceOffering","updateServiceOffering","listServiceOfferings","createDiskOffering","updateDiskOffering","deleteDiskOffering","listDiskOfferings","createVlanIpRange","deleteVlanIpRange","listVlanIpRanges","dedicatePublicIpRange","releasePublicIpRange","dedicateGuestVlanRange","releaseDedicatedGuestVlanRange","listDedicatedGuestVlanRanges","associateIpAddress","disassociateIpAddress","listPublicIpAddresses","listPortForwardingRules","createPortForwardingRule","deletePortForwardingRule","updatePortForwardingRule","enableStaticNat","createIpForwardingRule","deleteIpForwardingRule","listIpForwardingRules","disableStaticN
 at","createLoadBalancerRule","deleteLoadBalancerRule","removeFromLoadBalancerRule","assignToLoadBalancerRule","createLBStickinessPolicy","deleteLBStickinessPolicy","listLoadBalancerRules","listLBStickinessPolicies","listLBHealthCheckPolicies","createLBHealthCheckPolicy","deleteLBHealthCheckPolicy","listLoadBalancerRuleInstances","updateLoadBalancerRule","createCounter","createCondition","createAutoScalePolicy","createAutoScaleVmProfile","createAutoScaleVmGroup","deleteCounter","deleteCondition","deleteAutoScalePolicy","deleteAutoScaleVmProfile","deleteAutoScaleVmGroup","listCounters","listConditions","listAutoScalePolicies","listAutoScaleVmProfiles","listAutoScaleVmGroups","enableAutoScaleVmGroup","disableAutoScaleVmGroup","updateAutoScalePolicy","updateAutoScaleVmProfile","updateAutoScaleVmGroup","startRouter","rebootRouter","stopRouter","destroyRouter","changeServiceForRouter","listRouters","listVirtualRouterElements","configureVirtualRouterElement","createVirtualRouterElement","s
 tartSystemVm","rebootSystemVm","stopSystemVm","destroySystemVm","listSystemVms","migrateSystemVm","changeServiceForSystemVm","scaleSystemVm","updateConfiguration","listConfigurations","listCapabilities","listDeploymentPlanners","cleanVMReservations","createPod","updatePod","deletePod","listPods","createZone","updateZone","deleteZone","listZones","listEvents","listEventTypes","archiveEvents","deleteEvents","listAlerts","archiveAlerts","deleteAlerts","listCapacity","addSwift","listSwifts","addS3","listS3s","addImageStore","listImageStores","deleteImageStore","createSecondaryStagingStore","listSecondaryStagingStores","deleteSecondaryStagingStore","addHost","addCluster","deleteCluster","updateCluster","reconnectHost","updateHost","deleteHost","prepareHostForMaintenance","cancelHostMaintenance","listHosts","findHostsForMigration","addSecondaryStorage","updateHostPassword","releaseHostReservation","attachVolume","uploadVolume","detachVolume","createVolume","deleteVolume","listVolumes","ex
 tractVolume","migrateVolume","resizeVolume","updateVolume","registerUserKeys","queryAsyncJobResult","listAsyncJobs","listStoragePools","listStorageProviders","createStoragePool","updateStoragePool","deleteStoragePool","listClusters","enableStorageMaintenance","cancelStorageMaintenance","findStoragePoolsForMigration","createSecurityGroup","deleteSecurityGroup","authorizeSecurityGroupIngress","revokeSecurityGroupIngress","authorizeSecurityGroupEgress","revokeSecurityGroupEgress","listSecurityGroups","createInstanceGroup","deleteInstanceGroup","updateInstanceGroup","listInstanceGroups","uploadCustomCertificate","listHypervisors","createRemoteAccessVpn","deleteRemoteAccessVpn","listRemoteAccessVpns","addVpnUser","removeVpnUser","listVpnUsers","createNetworkOffering","updateNetworkOffering","deleteNetworkOffering","listNetworkOfferings","createNetwork","deleteNetwork","listNetworks","restartNetwork","updateNetwork","addNicToVirtualMachine","removeNicFromVirtualMachine","updateDefaultNicF
 orVirtualMachine","addIpToNic","removeIpFromNic","listNics","registerSSHKeyPair","createSSHKeyPair","deleteSSHKeyPair","listSSHKeyPairs","createProject","deleteProject","updateProject","activateProject","suspendProject","listProjects","addAccountToProject","deleteAccountFromProject","listProjectAccounts","listProjectInvitations","updateProjectInvitation","deleteProjectInvitation","createFirewallRule","deleteFirewallRule","listFirewallRules","createEgressFirewallRule","deleteEgressFirewallRule","listEgressFirewallRules","updateHypervisorCapabilities","listHypervisorCapabilities","createPhysicalNetwork","deletePhysicalNetwork","listPhysicalNetworks","updatePhysicalNetwork","listSupportedNetworkServices","addNetworkServiceProvider","deleteNetworkServiceProvider","listNetworkServiceProviders","updateNetworkServiceProvider","addTrafficType","deleteTrafficType","listTrafficTypes","updateTrafficType","listTrafficTypeImplementors","createStorageNetworkIpRange","deleteStorageNetworkIpRange",
 "listStorageNetworkIpRange","updateStorageNetworkIpRange","addNetworkDevice","listNetworkDevice","deleteNetworkDevice","createVPC","listVPCs","deleteVPC","updateVPC","restartVPC","createVPCOffering","updateVPCOffering","deleteVPCOffering","listVPCOfferings","createPrivateGateway","listPrivateGateways","deletePrivateGateway","createNetworkACL","updateNetworkACLItem","deleteNetworkACL","listNetworkACLs","createNetworkACLList","deleteNetworkACLList","replaceNetworkACLList","listNetworkACLLists","createStaticRoute","deleteStaticRoute","listStaticRoutes","createTags","deleteTags","listTags","addResourceDetail","removeResourceDetail","listResourceDetails","createVpnCustomerGateway","createVpnGateway","createVpnConnection","deleteVpnCustomerGateway","deleteVpnGateway","deleteVpnConnection","updateVpnCustomerGateway","resetVpnConnection","listVpnCustomerGateways","listVpnGateways","listVpnConnections","generateUsageRecords","listUsageRecords","listUsageTypes","addTrafficMonitor","deleteTraf
 ficMonitor","listTrafficMonitors","addNiciraNvpDevice","deleteNiciraNvpDevice","listNiciraNvpDevices","listNiciraNvpDeviceNetworks","addBigSwitchVnsDevice","deleteBigSwitchVnsDevice","listBigSwitchVnsDevices","listApis","getApiLimit","resetApiLimit","addRegion","updateRegion","removeRegion","listRegions","createGlobalLoadBalancerRule","deleteGlobalLoadBalancerRule","updateGlobalLoadBalancerRule","listGlobalLoadBalancerRules","assignToGlobalLoadBalancerRule","removeFromGlobalLoadBalancerRule","listVMSnapshot","createVMSnapshot","deleteVMSnapshot","revertToVMSnapshot","addBaremetalHost","addBaremetalPxeKickStartServer","addBaremetalPxePingServer","addBaremetalDhcp","listBaremetalDhcp","listBaremetalPxeServers","addUcsManager","listUcsManagers","listUcsProfiles","listUcsBlades","associateUcsProfileToBlade","createLoadBalancer","listLoadBalancers","deleteLoadBalancer","configureInternalLoadBalancerElement","createInternalLoadBalancerElement","listInternalLoadBalancerElements","createAff
 inityGroup","deleteAffinityGroup","listAffinityGroups","updateVMAffinityGroup","listAffinityGroupTypes","createPortableIpRange","deletePortableIpRange","listPortableIpRanges","stopInternalLoadBalancerVM","startInternalLoadBalancerVM","listInternalLoadBalancerVMs","listNetworkIsolationMethods","dedicateZone","dedicatePod","dedicateCluster","dedicateHost","releaseDedicatedZone","releaseDedicatedPod","releaseDedicatedCluster","releaseDedicatedHost","listDedicatedZones","listDedicatedPods","listDedicatedClusters","listDedicatedHosts","listLdapConfigurations","addLdapConfiguration","deleteLdapConfiguration","listLdapUsers","ldapCreateAccount","login","logout","cloudstackAPIClient"]
\ No newline at end of file

http://git-wip-us.apache.org/repos/asf/cloudstack/blob/ec00a6fb/tools/marvin/build/lib/marvin/cloudstackAPI/activateProject.py
----------------------------------------------------------------------
diff --git a/tools/marvin/build/lib/marvin/cloudstackAPI/activateProject.py b/tools/marvin/build/lib/marvin/cloudstackAPI/activateProject.py
new file mode 100644
index 0000000..cd7c7a7
--- /dev/null
+++ b/tools/marvin/build/lib/marvin/cloudstackAPI/activateProject.py
@@ -0,0 +1,141 @@
+# Licensed to the Apache Software Foundation (ASF) under one
+# or more contributor license agreements.  See the NOTICE file
+# distributed with this work for additional information
+# regarding copyright ownership.  The ASF licenses this file
+# to you 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.
+
+
+"""Activates a project"""
+from baseCmd import *
+from baseResponse import *
+class activateProjectCmd (baseCmd):
+    def __init__(self):
+        self.isAsync = "true"
+        """id of the project to be modified"""
+        """Required"""
+        self.id = None
+        self.required = ["id",]
+
+class activateProjectResponse (baseResponse):
+    def __init__(self):
+        """the id of the project"""
+        self.id = None
+        """the account name of the project's owner"""
+        self.account = None
+        """the total number of cpu cores available to be created for this project"""
+        self.cpuavailable = None
+        """the total number of cpu cores the project can own"""
+        self.cpulimit = None
+        """the total number of cpu cores owned by project"""
+        self.cputotal = None
+        """the displaytext of the project"""
+        self.displaytext = None
+        """the domain name where the project belongs to"""
+        self.domain = None
+        """the domain id the project belongs to"""
+        self.domainid = None
+        """the total number of public ip addresses available for this project to acquire"""
+        self.ipavailable = None
+        """the total number of public ip addresses this project can acquire"""
+        self.iplimit = None
+        """the total number of public ip addresses allocated for this project"""
+        self.iptotal = None
+        """the total memory (in MB) available to be created for this project"""
+        self.memoryavailable = None
+        """the total memory (in MB) the project can own"""
+        self.memorylimit = None
+        """the total memory (in MB) owned by project"""
+        self.memorytotal = None
+        """the name of the project"""
+        self.name = None
+        """the total number of networks available to be created for this project"""
+        self.networkavailable = None
+        """the total number of networks the project can own"""
+        self.networklimit = None
+        """the total number of networks owned by project"""
+        self.networktotal = None
+        """the total primary storage space (in GiB) available to be used for this project"""
+        self.primarystorageavailable = None
+        """the total primary storage space (in GiB) the project can own"""
+        self.primarystoragelimit = None
+        """the total primary storage space (in GiB) owned by project"""
+        self.primarystoragetotal = None
+        """the total secondary storage space (in GiB) available to be used for this project"""
+        self.secondarystorageavailable = None
+        """the total secondary storage space (in GiB) the project can own"""
+        self.secondarystoragelimit = None
+        """the total secondary storage space (in GiB) owned by project"""
+        self.secondarystoragetotal = None
+        """the total number of snapshots available for this project"""
+        self.snapshotavailable = None
+        """the total number of snapshots which can be stored by this project"""
+        self.snapshotlimit = None
+        """the total number of snapshots stored by this project"""
+        self.snapshottotal = None
+        """the state of the project"""
+        self.state = None
+        """the total number of templates available to be created by this project"""
+        self.templateavailable = None
+        """the total number of templates which can be created by this project"""
+        self.templatelimit = None
+        """the total number of templates which have been created by this project"""
+        self.templatetotal = None
+        """the total number of virtual machines available for this project to acquire"""
+        self.vmavailable = None
+        """the total number of virtual machines that can be deployed by this project"""
+        self.vmlimit = None
+        """the total number of virtual machines running for this project"""
+        self.vmrunning = None
+        """the total number of virtual machines stopped for this project"""
+        self.vmstopped = None
+        """the total number of virtual machines deployed by this project"""
+        self.vmtotal = None
+        """the total volume available for this project"""
+        self.volumeavailable = None
+        """the total volume which can be used by this project"""
+        self.volumelimit = None
+        """the total volume being used by this project"""
+        self.volumetotal = None
+        """the total number of vpcs available to be created for this project"""
+        self.vpcavailable = None
+        """the total number of vpcs the project can own"""
+        self.vpclimit = None
+        """the total number of vpcs owned by project"""
+        self.vpctotal = None
+        """the list of resource tags associated with vm"""
+        self.tags = []
+
+class tags:
+    def __init__(self):
+        """"the account associated with the tag"""
+        self.account = None
+        """"customer associated with the tag"""
+        self.customer = None
+        """"the domain associated with the tag"""
+        self.domain = None
+        """"the ID of the domain associated with the tag"""
+        self.domainid = None
+        """"tag key name"""
+        self.key = None
+        """"the project name where tag belongs to"""
+        self.project = None
+        """"the project id the tag belongs to"""
+        self.projectid = None
+        """"id of the resource"""
+        self.resourceid = None
+        """"resource type"""
+        self.resourcetype = None
+        """"tag value"""
+        self.value = None
+

http://git-wip-us.apache.org/repos/asf/cloudstack/blob/ec00a6fb/tools/marvin/build/lib/marvin/cloudstackAPI/addAccountToProject.py
----------------------------------------------------------------------
diff --git a/tools/marvin/build/lib/marvin/cloudstackAPI/addAccountToProject.py b/tools/marvin/build/lib/marvin/cloudstackAPI/addAccountToProject.py
new file mode 100644
index 0000000..211c58d
--- /dev/null
+++ b/tools/marvin/build/lib/marvin/cloudstackAPI/addAccountToProject.py
@@ -0,0 +1,40 @@
+# Licensed to the Apache Software Foundation (ASF) under one
+# or more contributor license agreements.  See the NOTICE file
+# distributed with this work for additional information
+# regarding copyright ownership.  The ASF licenses this file
+# to you 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.
+
+
+"""Adds acoount to a project"""
+from baseCmd import *
+from baseResponse import *
+class addAccountToProjectCmd (baseCmd):
+    def __init__(self):
+        self.isAsync = "true"
+        """id of the project to add the account to"""
+        """Required"""
+        self.projectid = None
+        """name of the account to be added to the project"""
+        self.account = None
+        """email to which invitation to the project is going to be sent"""
+        self.email = None
+        self.required = ["projectid",]
+
+class addAccountToProjectResponse (baseResponse):
+    def __init__(self):
+        """any text associated with the success or failure"""
+        self.displaytext = None
+        """true if operation is executed successfully"""
+        self.success = None
+

http://git-wip-us.apache.org/repos/asf/cloudstack/blob/ec00a6fb/tools/marvin/build/lib/marvin/cloudstackAPI/addBaremetalDhcp.py
----------------------------------------------------------------------
diff --git a/tools/marvin/build/lib/marvin/cloudstackAPI/addBaremetalDhcp.py b/tools/marvin/build/lib/marvin/cloudstackAPI/addBaremetalDhcp.py
new file mode 100644
index 0000000..fa8b095
--- /dev/null
+++ b/tools/marvin/build/lib/marvin/cloudstackAPI/addBaremetalDhcp.py
@@ -0,0 +1,54 @@
+# Licensed to the Apache Software Foundation (ASF) under one
+# or more contributor license agreements.  See the NOTICE file
+# distributed with this work for additional information
+# regarding copyright ownership.  The ASF licenses this file
+# to you 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.
+
+
+"""adds a baremetal dhcp server"""
+from baseCmd import *
+from baseResponse import *
+class addBaremetalDhcpCmd (baseCmd):
+    def __init__(self):
+        self.isAsync = "true"
+        """Type of dhcp device"""
+        """Required"""
+        self.dhcpservertype = None
+        """Credentials to reach external dhcp device"""
+        """Required"""
+        self.password = None
+        """the Physical Network ID"""
+        """Required"""
+        self.physicalnetworkid = None
+        """URL of the external dhcp appliance."""
+        """Required"""
+        self.url = None
+        """Credentials to reach external dhcp device"""
+        """Required"""
+        self.username = None
+        self.required = ["dhcpservertype","password","physicalnetworkid","url","username",]
+
+class addBaremetalDhcpResponse (baseResponse):
+    def __init__(self):
+        """device id of"""
+        self.id = None
+        """name of the provider"""
+        self.dhcpservertype = None
+        """the physical network to which this external dhcp device belongs to"""
+        self.physicalnetworkid = None
+        """name of the provider"""
+        self.provider = None
+        """url"""
+        self.url = None
+

http://git-wip-us.apache.org/repos/asf/cloudstack/blob/ec00a6fb/tools/marvin/build/lib/marvin/cloudstackAPI/addBaremetalHost.py
----------------------------------------------------------------------
diff --git a/tools/marvin/build/lib/marvin/cloudstackAPI/addBaremetalHost.py b/tools/marvin/build/lib/marvin/cloudstackAPI/addBaremetalHost.py
new file mode 100644
index 0000000..6fb003e
--- /dev/null
+++ b/tools/marvin/build/lib/marvin/cloudstackAPI/addBaremetalHost.py
@@ -0,0 +1,147 @@
+# Licensed to the Apache Software Foundation (ASF) under one
+# or more contributor license agreements.  See the NOTICE file
+# distributed with this work for additional information
+# regarding copyright ownership.  The ASF licenses this file
+# to you 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.
+
+
+"""add a baremetal host"""
+from baseCmd import *
+from baseResponse import *
+class addBaremetalHostCmd (baseCmd):
+    def __init__(self):
+        self.isAsync = "false"
+        """hypervisor type of the host"""
+        """Required"""
+        self.hypervisor = None
+        """the password for the host"""
+        """Required"""
+        self.password = None
+        """the Pod ID for the host"""
+        """Required"""
+        self.podid = None
+        """the host URL"""
+        """Required"""
+        self.url = None
+        """the username for the host"""
+        """Required"""
+        self.username = None
+        """the Zone ID for the host"""
+        """Required"""
+        self.zoneid = None
+        """Allocation state of this Host for allocation of new resources"""
+        self.allocationstate = None
+        """the cluster ID for the host"""
+        self.clusterid = None
+        """the cluster name for the host"""
+        self.clustername = None
+        """list of tags to be added to the host"""
+        self.hosttags = []
+        """ip address intentionally allocated to this host after provisioning"""
+        self.ipaddress = None
+        self.required = ["hypervisor","password","podid","url","username","zoneid",]
+
+class addBaremetalHostResponse (baseResponse):
+    def __init__(self):
+        """the ID of the host"""
+        self.id = None
+        """the cpu average load on the host"""
+        self.averageload = None
+        """capabilities of the host"""
+        self.capabilities = None
+        """the cluster ID of the host"""
+        self.clusterid = None
+        """the cluster name of the host"""
+        self.clustername = None
+        """the cluster type of the cluster that host belongs to"""
+        self.clustertype = None
+        """the amount of the host's CPU currently allocated"""
+        self.cpuallocated = None
+        """the CPU number of the host"""
+        self.cpunumber = None
+        """the CPU speed of the host"""
+        self.cpuspeed = None
+        """the amount of the host's CPU currently used"""
+        self.cpuused = None
+        """the amount of the host's CPU after applying the cpu.overprovisioning.factor"""
+        self.cpuwithoverprovisioning = None
+        """the date and time the host was created"""
+        self.created = None
+        """true if the host is disconnected. False otherwise."""
+        self.disconnected = None
+        """the host's currently allocated disk size"""
+        self.disksizeallocated = None
+        """the total disk size of the host"""
+        self.disksizetotal = None
+        """events available for the host"""
+        self.events = None
+        """true if the host is Ha host (dedicated to vms started by HA process; false otherwise"""
+        self.hahost = None
+        """true if this host has enough CPU and RAM capacity to migrate a VM to it, false otherwise"""
+        self.hasenoughcapacity = None
+        """comma-separated list of tags for the host"""
+        self.hosttags = None
+        """the host hypervisor"""
+        self.hypervisor = None
+        """the hypervisor version"""
+        self.hypervisorversion = None
+        """the IP address of the host"""
+        self.ipaddress = None
+        """true if local storage is active, false otherwise"""
+        self.islocalstorageactive = None
+        """the date and time the host was last pinged"""
+        self.lastpinged = None
+        """the management server ID of the host"""
+        self.managementserverid = None
+        """the amount of the host's memory currently allocated"""
+        self.memoryallocated = None
+        """the memory total of the host"""
+        self.memorytotal = None
+        """the amount of the host's memory currently used"""
+        self.memoryused = None
+        """the name of the host"""
+        self.name = None
+        """the incoming network traffic on the host"""
+        self.networkkbsread = None
+        """the outgoing network traffic on the host"""
+        self.networkkbswrite = None
+        """the OS category ID of the host"""
+        self.oscategoryid = None
+        """the OS category name of the host"""
+        self.oscategoryname = None
+        """the Pod ID of the host"""
+        self.podid = None
+        """the Pod name of the host"""
+        self.podname = None
+        """the date and time the host was removed"""
+        self.removed = None
+        """the resource state of the host"""
+        self.resourcestate = None
+        """the state of the host"""
+        self.state = None
+        """true if this host is suitable(has enough capacity and satisfies all conditions like hosttags, max guests vm limit etc) to migrate a VM to it , false otherwise"""
+        self.suitableformigration = None
+        """the host type"""
+        self.type = None
+        """the host version"""
+        self.version = None
+        """the Zone ID of the host"""
+        self.zoneid = None
+        """the Zone name of the host"""
+        self.zonename = None
+        """the ID of the latest async job acting on this object"""
+        self.jobid = None
+        """the current status of the latest async job acting on this object"""
+        self.jobstatus = None
+

http://git-wip-us.apache.org/repos/asf/cloudstack/blob/ec00a6fb/tools/marvin/build/lib/marvin/cloudstackAPI/addBaremetalPxeKickStartServer.py
----------------------------------------------------------------------
diff --git a/tools/marvin/build/lib/marvin/cloudstackAPI/addBaremetalPxeKickStartServer.py b/tools/marvin/build/lib/marvin/cloudstackAPI/addBaremetalPxeKickStartServer.py
new file mode 100644
index 0000000..14a1237
--- /dev/null
+++ b/tools/marvin/build/lib/marvin/cloudstackAPI/addBaremetalPxeKickStartServer.py
@@ -0,0 +1,51 @@
+# Licensed to the Apache Software Foundation (ASF) under one
+# or more contributor license agreements.  See the NOTICE file
+# distributed with this work for additional information
+# regarding copyright ownership.  The ASF licenses this file
+# to you 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.
+
+
+"""add a baremetal pxe server"""
+from baseCmd import *
+from baseResponse import *
+class addBaremetalPxeKickStartServerCmd (baseCmd):
+    def __init__(self):
+        self.isAsync = "true"
+        """Credentials to reach external pxe device"""
+        """Required"""
+        self.password = None
+        """the Physical Network ID"""
+        """Required"""
+        self.physicalnetworkid = None
+        """type of pxe device"""
+        """Required"""
+        self.pxeservertype = None
+        """Tftp root directory of PXE server"""
+        """Required"""
+        self.tftpdir = None
+        """URL of the external pxe device"""
+        """Required"""
+        self.url = None
+        """Credentials to reach external pxe device"""
+        """Required"""
+        self.username = None
+        """Pod Id"""
+        self.podid = None
+        self.required = ["password","physicalnetworkid","pxeservertype","tftpdir","url","username",]
+
+class addBaremetalPxeKickStartServerResponse (baseResponse):
+    def __init__(self):
+        """Tftp root directory of PXE server"""
+        self.tftpdir = None
+

http://git-wip-us.apache.org/repos/asf/cloudstack/blob/ec00a6fb/tools/marvin/build/lib/marvin/cloudstackAPI/addBaremetalPxePingServer.py
----------------------------------------------------------------------
diff --git a/tools/marvin/build/lib/marvin/cloudstackAPI/addBaremetalPxePingServer.py b/tools/marvin/build/lib/marvin/cloudstackAPI/addBaremetalPxePingServer.py
new file mode 100644
index 0000000..6e3d6bf
--- /dev/null
+++ b/tools/marvin/build/lib/marvin/cloudstackAPI/addBaremetalPxePingServer.py
@@ -0,0 +1,65 @@
+# Licensed to the Apache Software Foundation (ASF) under one
+# or more contributor license agreements.  See the NOTICE file
+# distributed with this work for additional information
+# regarding copyright ownership.  The ASF licenses this file
+# to you 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.
+
+
+"""add a baremetal ping pxe server"""
+from baseCmd import *
+from baseResponse import *
+class addBaremetalPxePingServerCmd (baseCmd):
+    def __init__(self):
+        self.isAsync = "true"
+        """Credentials to reach external pxe device"""
+        """Required"""
+        self.password = None
+        """the Physical Network ID"""
+        """Required"""
+        self.physicalnetworkid = None
+        """Root directory on PING storage server"""
+        """Required"""
+        self.pingdir = None
+        """PING storage server ip"""
+        """Required"""
+        self.pingstorageserverip = None
+        """type of pxe device"""
+        """Required"""
+        self.pxeservertype = None
+        """Tftp root directory of PXE server"""
+        """Required"""
+        self.tftpdir = None
+        """URL of the external pxe device"""
+        """Required"""
+        self.url = None
+        """Credentials to reach external pxe device"""
+        """Required"""
+        self.username = None
+        """Password of PING storage server"""
+        self.pingcifspassword = None
+        """Username of PING storage server"""
+        self.pingcifsusername = None
+        """Pod Id"""
+        self.podid = None
+        self.required = ["password","physicalnetworkid","pingdir","pingstorageserverip","pxeservertype","tftpdir","url","username",]
+
+class addBaremetalPxePingServerResponse (baseResponse):
+    def __init__(self):
+        """Root directory on PING storage server"""
+        self.pingdir = None
+        """PING storage server ip"""
+        self.pingstorageserverip = None
+        """Tftp root directory of PXE server"""
+        self.tftpdir = None
+

http://git-wip-us.apache.org/repos/asf/cloudstack/blob/ec00a6fb/tools/marvin/build/lib/marvin/cloudstackAPI/addBigSwitchVnsDevice.py
----------------------------------------------------------------------
diff --git a/tools/marvin/build/lib/marvin/cloudstackAPI/addBigSwitchVnsDevice.py b/tools/marvin/build/lib/marvin/cloudstackAPI/addBigSwitchVnsDevice.py
new file mode 100644
index 0000000..77a7476
--- /dev/null
+++ b/tools/marvin/build/lib/marvin/cloudstackAPI/addBigSwitchVnsDevice.py
@@ -0,0 +1,45 @@
+# Licensed to the Apache Software Foundation (ASF) under one
+# or more contributor license agreements.  See the NOTICE file
+# distributed with this work for additional information
+# regarding copyright ownership.  The ASF licenses this file
+# to you 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.
+
+
+"""Adds a BigSwitch VNS device"""
+from baseCmd import *
+from baseResponse import *
+class addBigSwitchVnsDeviceCmd (baseCmd):
+    def __init__(self):
+        self.isAsync = "true"
+        """Hostname of ip address of the BigSwitch VNS Controller."""
+        """Required"""
+        self.hostname = None
+        """the Physical Network ID"""
+        """Required"""
+        self.physicalnetworkid = None
+        self.required = ["hostname","physicalnetworkid",]
+
+class addBigSwitchVnsDeviceResponse (baseResponse):
+    def __init__(self):
+        """device name"""
+        self.bigswitchdevicename = None
+        """the controller Ip address"""
+        self.hostname = None
+        """the physical network to which this BigSwitch Vns belongs to"""
+        self.physicalnetworkid = None
+        """name of the provider"""
+        self.provider = None
+        """device id of the BigSwitch Vns"""
+        self.vnsdeviceid = None
+

http://git-wip-us.apache.org/repos/asf/cloudstack/blob/ec00a6fb/tools/marvin/build/lib/marvin/cloudstackAPI/addCluster.py
----------------------------------------------------------------------
diff --git a/tools/marvin/build/lib/marvin/cloudstackAPI/addCluster.py b/tools/marvin/build/lib/marvin/cloudstackAPI/addCluster.py
new file mode 100644
index 0000000..26d7f6c
--- /dev/null
+++ b/tools/marvin/build/lib/marvin/cloudstackAPI/addCluster.py
@@ -0,0 +1,115 @@
+# Licensed to the Apache Software Foundation (ASF) under one
+# or more contributor license agreements.  See the NOTICE file
+# distributed with this work for additional information
+# regarding copyright ownership.  The ASF licenses this file
+# to you 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.
+
+
+"""Adds a new cluster"""
+from baseCmd import *
+from baseResponse import *
+class addClusterCmd (baseCmd):
+    def __init__(self):
+        self.isAsync = "false"
+        """the cluster name"""
+        """Required"""
+        self.clustername = None
+        """type of the cluster: CloudManaged, ExternalManaged"""
+        """Required"""
+        self.clustertype = None
+        """hypervisor type of the cluster: XenServer,KVM,VMware,Hyperv,BareMetal,Simulator"""
+        """Required"""
+        self.hypervisor = None
+        """the Pod ID for the host"""
+        """Required"""
+        self.podid = None
+        """the Zone ID for the cluster"""
+        """Required"""
+        self.zoneid = None
+        """Allocation state of this cluster for allocation of new resources"""
+        self.allocationstate = None
+        """Name of virtual switch used for guest traffic in the cluster. This would override zone wide traffic label setting."""
+        self.guestvswitchname = None
+        """Type of virtual switch used for guest traffic in the cluster. Allowed values are, vmwaresvs (for VMware standard vSwitch) and vmwaredvs (for VMware distributed vSwitch)"""
+        self.guestvswitchtype = None
+        """the password for the host"""
+        self.password = None
+        """Name of virtual switch used for public traffic in the cluster.  This would override zone wide traffic label setting."""
+        self.publicvswitchname = None
+        """Type of virtual switch used for public traffic in the cluster. Allowed values are, vmwaresvs (for VMware standard vSwitch) and vmwaredvs (for VMware distributed vSwitch)"""
+        self.publicvswitchtype = None
+        """the URL"""
+        self.url = None
+        """the username for the cluster"""
+        self.username = None
+        """the ipaddress of the VSM associated with this cluster"""
+        self.vsmipaddress = None
+        """the password for the VSM associated with this cluster"""
+        self.vsmpassword = None
+        """the username for the VSM associated with this cluster"""
+        self.vsmusername = None
+        self.required = ["clustername","clustertype","hypervisor","podid","zoneid",]
+
+class addClusterResponse (baseResponse):
+    def __init__(self):
+        """the cluster ID"""
+        self.id = None
+        """the allocation state of the cluster"""
+        self.allocationstate = None
+        """the type of the cluster"""
+        self.clustertype = None
+        """The cpu overcommit ratio of the cluster"""
+        self.cpuovercommitratio = None
+        """the hypervisor type of the cluster"""
+        self.hypervisortype = None
+        """whether this cluster is managed by cloudstack"""
+        self.managedstate = None
+        """The memory overcommit ratio of the cluster"""
+        self.memoryovercommitratio = None
+        """the cluster name"""
+        self.name = None
+        """the Pod ID of the cluster"""
+        self.podid = None
+        """the Pod name of the cluster"""
+        self.podname = None
+        """the Zone ID of the cluster"""
+        self.zoneid = None
+        """the Zone name of the cluster"""
+        self.zonename = None
+        """the capacity of the Cluster"""
+        self.capacity = []
+
+class capacity:
+    def __init__(self):
+        """"the total capacity available"""
+        self.capacitytotal = None
+        """"the capacity currently in use"""
+        self.capacityused = None
+        """"the Cluster ID"""
+        self.clusterid = None
+        """"the Cluster name"""
+        self.clustername = None
+        """"the percentage of capacity currently in use"""
+        self.percentused = None
+        """"the Pod ID"""
+        self.podid = None
+        """"the Pod name"""
+        self.podname = None
+        """"the capacity type"""
+        self.type = None
+        """"the Zone ID"""
+        self.zoneid = None
+        """"the Zone name"""
+        self.zonename = None
+

http://git-wip-us.apache.org/repos/asf/cloudstack/blob/ec00a6fb/tools/marvin/build/lib/marvin/cloudstackAPI/addHost.py
----------------------------------------------------------------------
diff --git a/tools/marvin/build/lib/marvin/cloudstackAPI/addHost.py b/tools/marvin/build/lib/marvin/cloudstackAPI/addHost.py
new file mode 100644
index 0000000..c1a96e0
--- /dev/null
+++ b/tools/marvin/build/lib/marvin/cloudstackAPI/addHost.py
@@ -0,0 +1,145 @@
+# Licensed to the Apache Software Foundation (ASF) under one
+# or more contributor license agreements.  See the NOTICE file
+# distributed with this work for additional information
+# regarding copyright ownership.  The ASF licenses this file
+# to you 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.
+
+
+"""Adds a new host."""
+from baseCmd import *
+from baseResponse import *
+class addHostCmd (baseCmd):
+    def __init__(self):
+        self.isAsync = "false"
+        """hypervisor type of the host"""
+        """Required"""
+        self.hypervisor = None
+        """the password for the host"""
+        """Required"""
+        self.password = None
+        """the Pod ID for the host"""
+        """Required"""
+        self.podid = None
+        """the host URL"""
+        """Required"""
+        self.url = None
+        """the username for the host"""
+        """Required"""
+        self.username = None
+        """the Zone ID for the host"""
+        """Required"""
+        self.zoneid = None
+        """Allocation state of this Host for allocation of new resources"""
+        self.allocationstate = None
+        """the cluster ID for the host"""
+        self.clusterid = None
+        """the cluster name for the host"""
+        self.clustername = None
+        """list of tags to be added to the host"""
+        self.hosttags = []
+        self.required = ["hypervisor","password","podid","url","username","zoneid",]
+
+class addHostResponse (baseResponse):
+    def __init__(self):
+        """the ID of the host"""
+        self.id = None
+        """the cpu average load on the host"""
+        self.averageload = None
+        """capabilities of the host"""
+        self.capabilities = None
+        """the cluster ID of the host"""
+        self.clusterid = None
+        """the cluster name of the host"""
+        self.clustername = None
+        """the cluster type of the cluster that host belongs to"""
+        self.clustertype = None
+        """the amount of the host's CPU currently allocated"""
+        self.cpuallocated = None
+        """the CPU number of the host"""
+        self.cpunumber = None
+        """the CPU speed of the host"""
+        self.cpuspeed = None
+        """the amount of the host's CPU currently used"""
+        self.cpuused = None
+        """the amount of the host's CPU after applying the cpu.overprovisioning.factor"""
+        self.cpuwithoverprovisioning = None
+        """the date and time the host was created"""
+        self.created = None
+        """true if the host is disconnected. False otherwise."""
+        self.disconnected = None
+        """the host's currently allocated disk size"""
+        self.disksizeallocated = None
+        """the total disk size of the host"""
+        self.disksizetotal = None
+        """events available for the host"""
+        self.events = None
+        """true if the host is Ha host (dedicated to vms started by HA process; false otherwise"""
+        self.hahost = None
+        """true if this host has enough CPU and RAM capacity to migrate a VM to it, false otherwise"""
+        self.hasenoughcapacity = None
+        """comma-separated list of tags for the host"""
+        self.hosttags = None
+        """the host hypervisor"""
+        self.hypervisor = None
+        """the hypervisor version"""
+        self.hypervisorversion = None
+        """the IP address of the host"""
+        self.ipaddress = None
+        """true if local storage is active, false otherwise"""
+        self.islocalstorageactive = None
+        """the date and time the host was last pinged"""
+        self.lastpinged = None
+        """the management server ID of the host"""
+        self.managementserverid = None
+        """the amount of the host's memory currently allocated"""
+        self.memoryallocated = None
+        """the memory total of the host"""
+        self.memorytotal = None
+        """the amount of the host's memory currently used"""
+        self.memoryused = None
+        """the name of the host"""
+        self.name = None
+        """the incoming network traffic on the host"""
+        self.networkkbsread = None
+        """the outgoing network traffic on the host"""
+        self.networkkbswrite = None
+        """the OS category ID of the host"""
+        self.oscategoryid = None
+        """the OS category name of the host"""
+        self.oscategoryname = None
+        """the Pod ID of the host"""
+        self.podid = None
+        """the Pod name of the host"""
+        self.podname = None
+        """the date and time the host was removed"""
+        self.removed = None
+        """the resource state of the host"""
+        self.resourcestate = None
+        """the state of the host"""
+        self.state = None
+        """true if this host is suitable(has enough capacity and satisfies all conditions like hosttags, max guests vm limit etc) to migrate a VM to it , false otherwise"""
+        self.suitableformigration = None
+        """the host type"""
+        self.type = None
+        """the host version"""
+        self.version = None
+        """the Zone ID of the host"""
+        self.zoneid = None
+        """the Zone name of the host"""
+        self.zonename = None
+        """the ID of the latest async job acting on this object"""
+        self.jobid = None
+        """the current status of the latest async job acting on this object"""
+        self.jobstatus = None
+

http://git-wip-us.apache.org/repos/asf/cloudstack/blob/ec00a6fb/tools/marvin/build/lib/marvin/cloudstackAPI/addImageStore.py
----------------------------------------------------------------------
diff --git a/tools/marvin/build/lib/marvin/cloudstackAPI/addImageStore.py b/tools/marvin/build/lib/marvin/cloudstackAPI/addImageStore.py
new file mode 100644
index 0000000..c8ea3e2
--- /dev/null
+++ b/tools/marvin/build/lib/marvin/cloudstackAPI/addImageStore.py
@@ -0,0 +1,58 @@
+# Licensed to the Apache Software Foundation (ASF) under one
+# or more contributor license agreements.  See the NOTICE file
+# distributed with this work for additional information
+# regarding copyright ownership.  The ASF licenses this file
+# to you 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.
+
+
+"""Adds backup image store."""
+from baseCmd import *
+from baseResponse import *
+class addImageStoreCmd (baseCmd):
+    def __init__(self):
+        self.isAsync = "false"
+        """the image store provider name"""
+        """Required"""
+        self.provider = None
+        """the details for the image store. Example: details[0].key=accesskey&details[0].value=s389ddssaa&details[1].key=secretkey&details[1].value=8dshfsss"""
+        self.details = []
+        """the name for the image store"""
+        self.name = None
+        """the URL for the image store"""
+        self.url = None
+        """the Zone ID for the image store"""
+        self.zoneid = None
+        self.required = ["provider",]
+
+class addImageStoreResponse (baseResponse):
+    def __init__(self):
+        """the ID of the image store"""
+        self.id = None
+        """the details of the image store"""
+        self.details = None
+        """the name of the image store"""
+        self.name = None
+        """the protocol of the image store"""
+        self.protocol = None
+        """the provider name of the image store"""
+        self.providername = None
+        """the scope of the image store"""
+        self.scope = None
+        """the url of the image store"""
+        self.url = None
+        """the Zone ID of the image store"""
+        self.zoneid = None
+        """the Zone name of the image store"""
+        self.zonename = None
+

http://git-wip-us.apache.org/repos/asf/cloudstack/blob/ec00a6fb/tools/marvin/build/lib/marvin/cloudstackAPI/addIpToNic.py
----------------------------------------------------------------------
diff --git a/tools/marvin/build/lib/marvin/cloudstackAPI/addIpToNic.py b/tools/marvin/build/lib/marvin/cloudstackAPI/addIpToNic.py
new file mode 100644
index 0000000..5810fe8
--- /dev/null
+++ b/tools/marvin/build/lib/marvin/cloudstackAPI/addIpToNic.py
@@ -0,0 +1,44 @@
+# Licensed to the Apache Software Foundation (ASF) under one
+# or more contributor license agreements.  See the NOTICE file
+# distributed with this work for additional information
+# regarding copyright ownership.  The ASF licenses this file
+# to you 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.
+
+
+"""Assigns secondary IP to NIC"""
+from baseCmd import *
+from baseResponse import *
+class addIpToNicCmd (baseCmd):
+    def __init__(self):
+        self.isAsync = "true"
+        """the ID of the nic to which you want to assign private IP"""
+        """Required"""
+        self.nicid = None
+        """Secondary IP Address"""
+        self.ipaddress = None
+        self.required = ["nicid",]
+
+class addIpToNicResponse (baseResponse):
+    def __init__(self):
+        """the ID of the secondary private IP addr"""
+        self.id = None
+        """Secondary IP address"""
+        self.ipaddress = None
+        """the ID of the network"""
+        self.networkid = None
+        """the ID of the nic"""
+        self.nicid = None
+        """the ID of the vm"""
+        self.virtualmachineid = None
+

http://git-wip-us.apache.org/repos/asf/cloudstack/blob/ec00a6fb/tools/marvin/build/lib/marvin/cloudstackAPI/addLdapConfiguration.py
----------------------------------------------------------------------
diff --git a/tools/marvin/build/lib/marvin/cloudstackAPI/addLdapConfiguration.py b/tools/marvin/build/lib/marvin/cloudstackAPI/addLdapConfiguration.py
new file mode 100644
index 0000000..993108e
--- /dev/null
+++ b/tools/marvin/build/lib/marvin/cloudstackAPI/addLdapConfiguration.py
@@ -0,0 +1,39 @@
+# Licensed to the Apache Software Foundation (ASF) under one
+# or more contributor license agreements.  See the NOTICE file
+# distributed with this work for additional information
+# regarding copyright ownership.  The ASF licenses this file
+# to you 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.
+
+
+"""Add a new Ldap Configuration"""
+from baseCmd import *
+from baseResponse import *
+class addLdapConfigurationCmd (baseCmd):
+    def __init__(self):
+        self.isAsync = "false"
+        """Hostname"""
+        """Required"""
+        self.hostname = None
+        """Port"""
+        """Required"""
+        self.port = None
+        self.required = ["hostname","port",]
+
+class addLdapConfigurationResponse (baseResponse):
+    def __init__(self):
+        """hostname"""
+        self.hostname = None
+        """port"""
+        self.port = None
+

http://git-wip-us.apache.org/repos/asf/cloudstack/blob/ec00a6fb/tools/marvin/build/lib/marvin/cloudstackAPI/addNetworkDevice.py
----------------------------------------------------------------------
diff --git a/tools/marvin/build/lib/marvin/cloudstackAPI/addNetworkDevice.py b/tools/marvin/build/lib/marvin/cloudstackAPI/addNetworkDevice.py
new file mode 100644
index 0000000..efd5b08
--- /dev/null
+++ b/tools/marvin/build/lib/marvin/cloudstackAPI/addNetworkDevice.py
@@ -0,0 +1,35 @@
+# Licensed to the Apache Software Foundation (ASF) under one
+# or more contributor license agreements.  See the NOTICE file
+# distributed with this work for additional information
+# regarding copyright ownership.  The ASF licenses this file
+# to you 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.
+
+
+"""Adds a network device of one of the following types: ExternalDhcp, ExternalFirewall, ExternalLoadBalancer, PxeServer"""
+from baseCmd import *
+from baseResponse import *
+class addNetworkDeviceCmd (baseCmd):
+    def __init__(self):
+        self.isAsync = "false"
+        """parameters for network device"""
+        self.networkdeviceparameterlist = []
+        """Network device type, now supports ExternalDhcp, PxeServer, NetscalerMPXLoadBalancer, NetscalerVPXLoadBalancer, NetscalerSDXLoadBalancer, F5BigIpLoadBalancer, JuniperSRXFirewall"""
+        self.networkdevicetype = None
+        self.required = []
+
+class addNetworkDeviceResponse (baseResponse):
+    def __init__(self):
+        """the ID of the network device"""
+        self.id = None
+

http://git-wip-us.apache.org/repos/asf/cloudstack/blob/ec00a6fb/tools/marvin/build/lib/marvin/cloudstackAPI/addNetworkServiceProvider.py
----------------------------------------------------------------------
diff --git a/tools/marvin/build/lib/marvin/cloudstackAPI/addNetworkServiceProvider.py b/tools/marvin/build/lib/marvin/cloudstackAPI/addNetworkServiceProvider.py
new file mode 100644
index 0000000..b00c204
--- /dev/null
+++ b/tools/marvin/build/lib/marvin/cloudstackAPI/addNetworkServiceProvider.py
@@ -0,0 +1,53 @@
+# Licensed to the Apache Software Foundation (ASF) under one
+# or more contributor license agreements.  See the NOTICE file
+# distributed with this work for additional information
+# regarding copyright ownership.  The ASF licenses this file
+# to you 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.
+
+
+"""Adds a network serviceProvider to a physical network"""
+from baseCmd import *
+from baseResponse import *
+class addNetworkServiceProviderCmd (baseCmd):
+    def __init__(self):
+        self.isAsync = "true"
+        """the name for the physical network service provider"""
+        """Required"""
+        self.name = None
+        """the Physical Network ID to add the provider to"""
+        """Required"""
+        self.physicalnetworkid = None
+        """the destination Physical Network ID to bridge to"""
+        self.destinationphysicalnetworkid = None
+        """the list of services to be enabled for this physical network service provider"""
+        self.servicelist = []
+        self.required = ["name","physicalnetworkid",]
+
+class addNetworkServiceProviderResponse (baseResponse):
+    def __init__(self):
+        """uuid of the network provider"""
+        self.id = None
+        """true if individual services can be enabled/disabled"""
+        self.canenableindividualservice = None
+        """the destination physical network"""
+        self.destinationphysicalnetworkid = None
+        """the provider name"""
+        self.name = None
+        """the physical network this belongs to"""
+        self.physicalnetworkid = None
+        """services for this provider"""
+        self.servicelist = None
+        """state of the network provider"""
+        self.state = None
+


Mime
View raw message