Merge pull request #7 from ribeiro-rodrigo/feature/lb_globo_create

Feature/lb globo create

Author: jeansfelix

README.md

@@ -44,6 +44,7 @@ url: http://localhost:8080/client/api
 * `lb_list_members` - list members from a LoadBalancer
 * `lb_attach_member` - Assigns virtual machine or a list of virtual machines to a load balancer
 * `lb_dettach_member` - Removes a virtual machine or a list of virtual machines from a load balancer
+* `lb_globo_create` - Creates a load balancer Globo
 
 ### AutoScale
 * `listAutoScaleVmGroups` - list listAutoScaleVmGroups

actions/lb_dettach_member.yaml

@@ -26,4 +26,4 @@ parameters:
   vm_ids:
     type: array
     description: Array of ID members atach LoadBalancer to retrieve members.
-    required: true
+    required: true

actions/lb_globo_create.py

@@ -0,0 +1,31 @@
+#!/usr/bin/env python
+
+from lib.cloudstack import CloudStackAPI
+
+__all__ = [
+    'LBGloboCreate'
+]
+
+
+class LBGloboCreate(CloudStackAPI):
+    def run(self, url, apikey, secretkey, name, algorithm, publicport,
+            privateport, projectid, openfirewall, networkid,
+            additionalportmap, healthchecktype, healthcheckrequest,
+            expectedhealthcheck, lbenvironmentid, timeoutrequest):
+
+        cs = self.get_client(url, apikey, secretkey, timeout=timeoutrequest)
+
+        return cs.createGloboLoadBalancer(
+            algorithm=algorithm,
+            name=name,
+            publicport=publicport,
+            projectid=projectid,
+            privateport=privateport,
+            openfirewall=str(openfirewall),
+            networkid=networkid,
+            additionalportmap=additionalportmap,
+            healthcheckType=healthchecktype,
+            healthcheckrequest=healthcheckrequest,
+            expectedhealthcheck=expectedhealthcheck,
+            lbenvironmentid=str(lbenvironmentid)
+        )

actions/lb_globo_create.yml

@@ -0,0 +1,78 @@
+---
+name: lb_globo_create
+runner_type: python-script
+description: Create Globo LoadBalancer
+enabled: true
+entry_point: lb_globo_create.py
+parameters:
+  url:
+    type: string
+    description: URL to use at ACS request
+    required: false
+  apikey:
+    type: string
+    description: API KEY to use at ACS request
+    required: true
+    secret: true
+  secretkey:
+    type: string
+    description: Secret KEY to use at ACS request
+    required: true
+    secret: true
+  name:
+    type: string
+    description: name of the load balancer
+    required: true
+  algorithm:
+    type: string
+    description: load balancer algorithm (source, roundrobin, leastconn)
+    required: true
+  publicport:
+    type: integer
+    description: the public port from where the network traffic will be load balanced from
+    required: true
+  privateport:
+    type: integer
+    description: the private port of the private IP address/virtual machine where the network traffic will be load balanced to
+    required: true
+  projectid:
+    type: string
+    description: id of the project to which the loadbalancer belongs
+    required: true
+  openfirewall:
+    type: boolean
+    description: id of the project to which the loadbalancer belongs
+    default: false
+    required: false
+  networkid:
+    type: string
+    description: The guest network this rule will be created for. Required when public Ip address is not associated with any Guest network yet (VPC case)
+    required: true
+  additionalportmap:
+    type: string
+    description: "Addional port map (pattern sample: 80:80)"
+    required: false
+  healthchecktype:
+    type: string
+    description: "Heath check protocol (example: HTTP, TCP)"
+    required: false
+    default: HTTP
+  healthcheckrequest:
+    type: string
+    description: "Path health check request (example: /healthcheck.html)"
+    required: false
+    default: "/"
+  expectedhealthcheck:
+    type: string
+    description: "Expected health check (example: 200 ok)"
+    required: false
+    default: "200 OK"
+  lbenvironmentid:
+    type: integer
+    description: "Load balancer environment id"
+    required: true
+  timeoutrequest:
+    type: integer
+    description: Timeout request in seconds
+    required: false
+    default: 35

actions/lib/cloudstack.py

@@ -12,7 +12,7 @@ class CloudStackAPI(Action):
     def __init__(self, config):
         super(CloudStackAPI, self).__init__(config=config)
 
-    def get_client(self, url, apikey, secretkey):
+    def get_client(self, url, apikey, secretkey, timeout=10):
         url_temp = self.config.get('url')
 
         if url != "" and url is not None:
@@ -23,5 +23,6 @@ def get_client(self, url, apikey, secretkey):
                         secret=secretkey,
                         dangerous_no_tls_verify=True,
                         fetch_result=True,
-                        method='POST')
+                        method='POST',
+                        timeout=timeout)
         return cs