test(ci): add volume provisioning test on cordoned node

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

tests/provision_test.go

@@ -149,6 +149,18 @@ func vgPatternMatchPresentTest() {
 	By("Deleting storage class", deleteStorageClass)
 }
 
+func scheduleOnCordonedNodeTest() {
+	device := setupVg(20, "lvmvg")
+	defer cleanupVg(device, "lvmvg")
+	By("Creating storage class", createStorageClass)
+	By("Cordoning the node", cordonk8sNode)
+	By("Creating and verifying PVC Bound status. It should not be Bound")
+	createAndVerifyPVC(false)
+	By("Uncordon the node", uncordonk8sNode)
+	By("Verify the PVC gets Bound")
+	verifyPVC("lvmpv-pvc", true)
+}
+
 func vgPatternNoMatchPresentTest() {
 	device := setupVg(20, "lvmvg212")
 	device_1 := setupVg(20, "lvmvg")
@@ -316,6 +328,7 @@ func schedulingTest() {
 	By("###Running vg specified in sc not present test###", vgSpecifiedNotPresentTest)
 	By("###Running lvmnode has vg matching vgpattern test###", vgPatternMatchPresentTest)
 	By("###Running lvmnode doesnt have vg matching vgpattern test###", vgPatternNoMatchPresentTest)
+	By("###Reuuning volume schedule on Cordoned node test###", scheduleOnCordonedNodeTest)
 }
 
 func capacityTest() {

tests/utils.go

@@ -3,6 +3,7 @@ package tests
 import (
 	"context"
 	"fmt"
+	"path/filepath"
 
 	"github.com/onsi/ginkgo"
 	"github.com/onsi/gomega"
@@ -12,6 +13,9 @@ import (
 	corev1 "k8s.io/api/core/v1"
 	k8serrors "k8s.io/apimachinery/pkg/api/errors"
 	metav1 "k8s.io/apimachinery/pkg/apis/meta/v1"
+	"k8s.io/client-go/kubernetes"
+	"k8s.io/client-go/tools/clientcmd"
+	"k8s.io/client-go/util/homedir"
 
 	"github.com/openebs/lvm-localpv/pkg/lvm"
 	"github.com/openebs/lvm-localpv/tests/container"
@@ -320,6 +324,18 @@ func createAndVerifyPVC(expect_bound bool) {
 	)
 }
 
+// Verifies state of already created pvc based on expect_bound.
+func verifyPVC(pvc_name string, expect_bound bool) {
+	ok := false
+	if !expect_bound {
+		ok = IsPVCPendingConsistently(pvc_name)
+	} else {
+		ok = IsPVCBoundEventually(pvc_name)
+	}
+	gomega.Expect(ok).To(gomega.Equal(true),
+		"while checking the pvc status")
+}
+
 func createAndVerifyBlockPVC(expect_bound bool) {
 	var (
 		err     error
@@ -819,3 +835,80 @@ func createNodeDaemonSet(ds *appsv1.DaemonSet) {
 		gomega.BeNil(),
 		"creating node plugin daemonset %v", nodeDaemonSet)
 }
+
+// Creates a k8s client using kubeconfig path.
+func getk8sClient() (client *kubernetes.Clientset) {
+	kubeconfigPath := filepath.Join(homedir.HomeDir(), ".kube", "config")
+	config, err := clientcmd.BuildConfigFromFlags("", kubeconfigPath)
+	gomega.Expect(err).To(
+		gomega.BeNil(),
+		"Could not created a k8s client",
+	)
+	client, c_err := kubernetes.NewForConfig(config)
+	gomega.Expect(c_err).To(
+		gomega.BeNil(),
+		"Could not created a k8s client",
+	)
+	return client
+}
+
+// Lists k8s nodes.
+func listNodes(client *kubernetes.Clientset) (nodes *corev1.NodeList) {
+	nodes, n_err := client.CoreV1().Nodes().List(context.TODO(), metav1.ListOptions{})
+	gomega.Expect(n_err).To(
+		gomega.BeNil(),
+		"Could not list nodes",
+	)
+	return nodes
+}
+
+// Cordons all k8s nodes.
+func cordonk8sNode() {
+	client := getk8sClient()
+	nodes := listNodes(client)
+	for _, node := range nodes.Items {
+		if !node.Spec.Unschedulable {
+			c_err := cordonNode(client, &node)
+			gomega.Expect(c_err).To(
+				gomega.BeNil(),
+				"Could not cordon node",
+			)
+		}
+
+	}
+}
+
+// UnCordons all k8s nodes.
+func uncordonk8sNode() {
+	client := getk8sClient()
+	nodes := listNodes(client)
+	for _, node := range nodes.Items {
+		if node.Spec.Unschedulable {
+			c_err := uncordonNode(client, &node)
+			gomega.Expect(c_err).To(
+				gomega.BeNil(),
+				"Could not uncordon node",
+			)
+		}
+	}
+}
+
+// Adds cordon taint to a specific node.
+func cordonNode(clientset *kubernetes.Clientset, node *corev1.Node) error {
+	updatedNode := node.DeepCopy()
+	updatedNode.Spec.Unschedulable = true
+
+	_, err := clientset.CoreV1().Nodes().Update(context.TODO(), updatedNode, metav1.UpdateOptions{})
+	return err
+
+}
+
+// Removes cordon taint from a specific node.
+func uncordonNode(clientset *kubernetes.Clientset, node *corev1.Node) error {
+	updatedNode := node.DeepCopy()
+	updatedNode.Spec.Unschedulable = false
+
+	_, err := clientset.CoreV1().Nodes().Update(context.TODO(), updatedNode, metav1.UpdateOptions{})
+	return err
+
+}