3 functions: setup, delete, test (haproxy)

clustersetuptest.py

@@ -0,0 +1,84 @@
+import os, subprocess, time
+sshpwd='test'
+ip='192.168.100.222'
+ipbind='192.168.100.231'
+nodes=['alpha', 'beta', 'gamma']
+loadcheck=[0, 0, 0]
+
+###to delete haproxy and clone-ip
+def Haprx_Cloneip_Deleter(ip):
+    os.system("sshpass -p "+sshpwd+" ssh -Y root@"+ip+" 'crm resource stop clone-ip; crm resource stop haproxy'")
+
+    time.sleep(3)
+    deletecommand='crm configure \
+    delete haproxy clone-ip'
+
+    os.system("sshpass -p "+sshpwd+" ssh root@"+ip+" '"+str(deletecommand)+"'")
+
+    proc = subprocess.Popen(["sshpass -p "+sshpwd+" ssh -Y root@"+ip+" 'crm status'"], stdout=subprocess.PIPE, shell=True)
+    (output2, err) = proc.communicate()
+    if not 'haproxy' in output2 and not 'clone-ip' in output2:
+        print '4.c) Successfully deleted haproxy and clone-ip!'
+
+
+###creates haproxy and clone-ip
+def ClusterConfigurer(ip):
+    global Haproxyrunnode
+    proc = subprocess.Popen(["sshpass -p "+sshpwd+" ssh -Y root@"+ip+" 'crm status'"], stdout=subprocess.PIPE, shell=True)
+    (output2, err) = proc.communicate()
+    temp = output2.split("\n")
+    haproxyflag=False
+    cloneipflag=False
+    for i in range(0, len(temp)):
+        if 'haproxy' in temp[i] and 'tarted' in temp[i]:
+            output = temp[i].split()
+            Haproxyrunnode = output[len(output)-1]
+            print '4.a) haproxy runs on node: '+Haproxyrunnode
+            haproxyflag=True  
+        if 'clone-ip' and 'admin-ip' in temp[i] and 'tarted' in temp[i+1]:
+            output = temp[i+1].split()
+            count=0
+            for j in range(0, len(output)):
+                if nodes[0] or nodes[1] or [nodes2] in output[j]:
+                    count+=1     
+            if count>=3:
+                print '4.b) Clone-Set of admin-ip runs on (at least) three nodes. Success.'
+            cloneipflag=True     
+    if haproxyflag==False:
+        haproxycfgcommand='crm configure \
+        primitive haproxy systemd:haproxy \
+        meta target-role=Started'
+        os.system("sshpass -p "+sshpwd+" ssh root@"+ip+" '"+str(haproxycfgcommand)+"'")
+        print '4.a.1) Successfully created primitive haproxy!'
+        ClusterConfigurer(ip)
+
+    if cloneipflag==False:
+        cloneipcommand='crm configure \
+        clone clone-ip admin-ip'
+        os.system("sshpass -p "+sshpwd+" ssh root@"+ip+" '"+str(cloneipcommand)+"'")
+        print '4.b.1) Successfully created clone-set "clone-ip"!'
+        ClusterConfigurer(ip)
+
+
+def ClusterTester(ipbind):
+ print '5.a) Starting the load balancer test...'
+ for j in range(0, 30):
+    time.sleep(3)
+    proc = subprocess.Popen(["curl -s "+ipbind], stdout=subprocess.PIPE, shell=True)
+    (output3, err) = proc.communicate()
+    if 'class' in output3 and 'rontend' in output3:
+        print 'it\'s the node on which haproxy runs...'+str(Haproxyrunnode)
+        for k in range(0, len(nodes)):
+            if str(nodes[k]) in str(Haproxyrunnode):
+                loadcheck[k]+=1
+    else:
+        for i in range(0, len(nodes)):
+            if nodes[i] in output3:
+                print 'it\'s the node: '+ nodes[i] 
+                loadcheck[i]+=1
+    proc.kill
+    print loadcheck
+
+
+
+