test(ci): adding vgops wrapper

Signed-off-by: Abhilash Shetty <[email protected]>

tests/lvm_utils.go

@@ -24,33 +24,6 @@ import (
 	"github.com/onsi/gomega"
 )
 
-// enable the monitoring on thinpool created for test, on local node which
-// is part of single node cluster.
-func enableThinpoolMonitoring() {
-	lv := VOLGROUP + "/" + pvcObj.Spec.VolumeName
-
-	args := []string{
-		"lvdisplay", "--columns",
-		"--options", "pool_lv",
-		"--noheadings",
-		lv,
-	}
-	stdout, _, err := execAtLocal("sudo", nil, args...)
-	gomega.Expect(err).ShouldNot(gomega.HaveOccurred(), "display LV")
-	gomega.Expect(strings.TrimSpace(string(stdout))).To(gomega.Not(gomega.Equal("")), "get thinpool LV")
-
-	thinpool := VOLGROUP + "/" + strings.TrimSpace(string(stdout))
-
-	args = []string{
-		"lvchange",
-		"--monitor", "y",
-		thinpool,
-	}
-
-	_, _, err = execAtLocal("sudo", nil, args...)
-	gomega.Expect(err).To(gomega.BeNil(), "run lvchange command")
-}
-
 // This creates loopdevice using the size passed as arg,
 // Uses the new loop device to create PV. returns loopdevice name to the caller.
 func createPV(size int) string {
@@ -62,7 +35,7 @@ func createPV(size int) string {
 		"--dry-run",
 	}
 	file, _, _ := execAtLocal("sudo", nil, back_file_args...)
-	
+
 	file_str := strings.TrimSpace(string(file[:]))
 	size_str := strconv.Itoa(size) + "G"
 	device_args := []string{
@@ -161,6 +134,33 @@ func removeVg(name string) {
 	gomega.Expect(err_vg).To(gomega.BeNil(), "vg remove failed")
 }
 
+// enable the monitoring on thinpool created for test, on local node which
+// is part of single node cluster.
+func enableThinpoolMonitoring() {
+	lv := VOLGROUP + "/" + pvcObj.Spec.VolumeName
+
+	args := []string{
+		"lvdisplay", "--columns",
+		"--options", "pool_lv",
+		"--noheadings",
+		lv,
+	}
+	stdout, _, err := execAtLocal("sudo", nil, args...)
+	gomega.Expect(err).ShouldNot(gomega.HaveOccurred(), "display LV")
+	gomega.Expect(strings.TrimSpace(string(stdout))).To(gomega.Not(gomega.Equal("")), "get thinpool LV")
+
+	thinpool := VOLGROUP + "/" + strings.TrimSpace(string(stdout))
+
+	args = []string{
+		"lvchange",
+		"--monitor", "y",
+		thinpool,
+	}
+
+	_, _, err = execAtLocal("sudo", nil, args...)
+	gomega.Expect(err).To(gomega.BeNil(), "run lvchange command")
+}
+
 // verify that the thinpool has extended in capacity to an expected size.
 func VerifyThinpoolExtend() {
 	expect_size, _ := strconv.ParseInt(expanded_capacity, 10, 64)