Skip to content

Commit

Permalink
test: added check for snapshot & clone in e2e
Browse files Browse the repository at this point in the history 
this test creates snapshots, restore the snapshots and creates clones.

Signed-off-by: riya-singhal31 <[email protected]>
  • Loading branch information
@riya-singhal31
riya-singhal31 committed Jun 27, 2022
1 parent c7d35ae commit 4b332bc
Show file tree
Hide file tree
Showing 2 changed files with 207 additions and 40 deletions.
200 changes: 162 additions & 38 deletions e2e/lvm/pvc_test.go
View file
Original file line number Diff line number Diff line change
Expand Up @@ -5,6 +5,7 @@ import (
"fmt"
"time"

snapapi "github.com/kubernetes-csi/external-snapshotter/client/v4/apis/volumesnapshot/v1"
. "github.com/onsi/ginkgo/v2"
. "github.com/onsi/gomega"
tests "github.com/red-hat-storage/lvm-operator/e2e"
Expand All @@ -15,75 +16,198 @@ import (
const (
timeout = time.Minute * 5
interval = time.Second * 30
size = "5Gi"
)

// Test to verify the PVC status
func PVCTest() {

Describe("PVC Tests", func() {
var filepvc *k8sv1.PersistentVolumeClaim
var filepod *k8sv1.Pod
var blockpvc *k8sv1.PersistentVolumeClaim
var blockpod *k8sv1.Pod
var pvc *k8sv1.PersistentVolumeClaim
var pod *k8sv1.Pod
var snapshot *snapapi.VolumeSnapshot
var clonePvc *k8sv1.PersistentVolumeClaim
var clonePod *k8sv1.Pod
var restorePvc *k8sv1.PersistentVolumeClaim
var restorePod *k8sv1.Pod
test := tests.DeployManagerObj.GetCrClient()

Context("create pvc, pod, snapshots, clones", func() {
It("Tests PVC operations for VolumeMode=file system", func() {
By("Creating pvc and pod")
pvc = tests.GetSamplePVC(tests.StorageClass, size, "lvmfilepvc", k8sv1.PersistentVolumeFilesystem)
pod = tests.GetSamplePod("lvmfilepod", pvc.Name)
err := test.Create(context.TODO(), pvc)
Expect(err).To(BeNil())
err = test.Create(context.TODO(), pod)
Expect(err).To(BeNil())

By("Verifying that the PVC(file system) is bound and the Pod is running")
Eventually(func() bool {
err := test.Get(context.TODO(), types.NamespacedName{Name: pvc.Name, Namespace: pvc.Namespace}, pvc)
return err == nil && pvc.Status.Phase == k8sv1.ClaimBound
}, timeout, interval).Should(BeTrue())
fmt.Printf("PVC %s is bound\n", pvc.Name)

Eventually(func() bool {
err = test.Get(context.TODO(), types.NamespacedName{Name: pod.Name, Namespace: pod.Namespace}, pod)
return err == nil && pod.Status.Phase == k8sv1.PodRunning
}, timeout, interval).Should(BeTrue())
fmt.Printf("Pod %s is running\n", pod.Name)

By("Creating a Snapshot of the file-pvc")
snapshot = tests.GetSampleVolumeSnapshot(pvc.Name, tests.StorageClass)
err = test.Create(context.TODO(), snapshot)
Expect(err).To(BeNil())
fmt.Printf("Snapshot %s is created\n", snapshot.Name)

By("Creating a clone of the file-pvc")
clonePvc = tests.GetPvc(size, pvc.Name, k8sv1.PersistentVolumeFilesystem, tests.StorageClass, "clone", "PersistentVolumeClaim")
err = test.Create(context.TODO(), clonePvc)
Expect(err).To(BeNil())
fmt.Printf("Cloned PVC %s is created\n", clonePvc.Name)

clonePod = tests.GetSamplePod("clone-lvmfilepod", clonePvc.Name)
err = test.Create(context.TODO(), clonePod)
Expect(err).To(BeNil())

Eventually(func() bool {
err := test.Get(context.TODO(), types.NamespacedName{Name: clonePvc.Name, Namespace: clonePvc.Namespace}, clonePvc)
return err == nil && clonePvc.Status.Phase == k8sv1.ClaimBound
}, timeout, interval).Should(BeTrue())
fmt.Printf("Cloned PVC %s is bound\n", clonePvc.Name)

By("Restore Snapshot for file-pvc")
restorePvc = tests.GetPvc(size, pvc.Name+"snapshot", k8sv1.PersistentVolumeFilesystem, tests.StorageClass, "restore", "VolumeSnapshot")
err = test.Create(context.TODO(), restorePvc)
Expect(err).To(BeNil())
fmt.Printf("Snapshot %s is restored\n", restorePvc.Name)

restorePod = tests.GetSamplePod("restore-lvmfilepod", restorePvc.Name)
err = test.Create(context.TODO(), restorePod)
Expect(err).To(BeNil())

Eventually(func() bool {
err := test.Get(context.TODO(), types.NamespacedName{Name: restorePvc.Name, Namespace: restorePvc.Namespace}, restorePvc)
return err == nil && restorePvc.Status.Phase == k8sv1.ClaimBound
}, timeout, interval).Should(BeTrue())
fmt.Printf("Restored PVC %s is bound\n", restorePvc.Name)

err = test.Delete(context.TODO(), clonePod)
Expect(err).To(BeNil())
fmt.Printf("Pod %s is deleted\n", clonePod.Name)

Context("create pvc and pod", func() {
It("Verifies the status", func() {
By("Creates pvc and pod")
filepvc = tests.GetSamplePVC(tests.StorageClass, "5Gi", "lvmfilepvc", k8sv1.PersistentVolumeFilesystem)
filepod = tests.GetSamplePod("lvmfilepod", "lvmfilepvc")
err := tests.DeployManagerObj.GetCrClient().Create(context.TODO(), filepvc)
err = test.Delete(context.TODO(), clonePvc)
Expect(err).To(BeNil())
err = tests.DeployManagerObj.GetCrClient().Create(context.TODO(), filepod)
fmt.Printf("Clone PVC %s is deleted\n", clonePvc.Name)

err = test.Delete(context.TODO(), restorePod)
Expect(err).To(BeNil())
fmt.Printf("Pod %s is deleted\n", restorePod.Name)

err = test.Delete(context.TODO(), restorePvc)
Expect(err).To(BeNil())
fmt.Printf("Restored Snapshot %s is deleted\n", restorePvc.Name)

blockpvc = tests.GetSamplePVC(tests.StorageClass, "5Gi", "lvmblockpvc", k8sv1.PersistentVolumeBlock)
blockpod = tests.GetSamplePod("lvmblockpod", "lvmblockpvc")
err = tests.DeployManagerObj.GetCrClient().Create(context.TODO(), blockpvc)
err = test.Delete(context.TODO(), snapshot)
Expect(err).To(BeNil())
err = tests.DeployManagerObj.GetCrClient().Create(context.TODO(), blockpod)
fmt.Printf("Snapshot %s is deleted\n", snapshot.Name)

err = test.Delete(context.TODO(), pod)
Expect(err).To(BeNil())
fmt.Printf("Pod %s is deleted\n", pod.Name)

err = test.Delete(context.TODO(), pvc)
Expect(err).To(BeNil())
fmt.Printf("PVC %s is deleted\n", pvc.Name)
})

By("PVC(file system) Should be bound and Pod should be running")
It("Tests PVC operations for VolumeMode=Block", func() {
By("Creating pvc and pod")
pvc = tests.GetSamplePVC(tests.StorageClass, size, "lvmblockpvc", k8sv1.PersistentVolumeBlock)
pod = tests.GetSamplePod("lvmblockpod", pvc.Name)
err := test.Create(context.TODO(), pvc)
Expect(err).To(BeNil())
err = test.Create(context.TODO(), pod)
Expect(err).To(BeNil())

By("Verifying that the PVC(block) is bound and the Pod is running")
Eventually(func() bool {
err := tests.DeployManagerObj.GetCrClient().Get(context.TODO(), types.NamespacedName{Name: filepvc.Name, Namespace: filepvc.Namespace}, filepvc)
return err == nil && filepvc.Status.Phase == k8sv1.ClaimBound
err := test.Get(context.TODO(), types.NamespacedName{Name: pvc.Name, Namespace: pvc.Namespace}, pvc)
return err == nil && pvc.Status.Phase == k8sv1.ClaimBound
}, timeout, interval).Should(BeTrue())
fmt.Printf("PVC %s is bound\n", filepvc.Name)
fmt.Printf("PVC %s is bound\n", pvc.Name)

Eventually(func() bool {
err = tests.DeployManagerObj.GetCrClient().Get(context.TODO(), types.NamespacedName{Name: filepod.Name, Namespace: filepod.Namespace}, filepod)
return err == nil && filepod.Status.Phase == k8sv1.PodRunning
err = test.Get(context.TODO(), types.NamespacedName{Name: pod.Name, Namespace: pod.Namespace}, pod)
return err == nil && pod.Status.Phase == k8sv1.PodRunning
}, timeout, interval).Should(BeTrue())
fmt.Printf("Pod %s is running\n", filepod.Name)
fmt.Printf("Pod %s is running\n", pod.Name)

err = tests.DeployManagerObj.GetCrClient().Delete(context.TODO(), filepod)
By("Creating a Snapshot of the block-pvc")
snapshot = tests.GetSampleVolumeSnapshot(pvc.Name, tests.StorageClass)
err = test.Create(context.TODO(), snapshot)
Expect(err).To(BeNil())
fmt.Printf("Pod %s is deleted\n", filepod.Name)
fmt.Printf("Snapshot %s is created\n", snapshot.Name)

err = tests.DeployManagerObj.GetCrClient().Delete(context.TODO(), filepvc)
By("Creating a clone of the block-pvc")
clonePvc = tests.GetPvc(size, pvc.Name, k8sv1.PersistentVolumeBlock, tests.StorageClass, "clone", "PersistentVolumeClaim")
err = test.Create(context.TODO(), clonePvc)
Expect(err).To(BeNil())
fmt.Printf("Cloned PVC %s is created\n", clonePvc.Name)

clonePod = tests.GetSamplePod("clone-lvmblockpod", "lvmblockpvcclone")
err = test.Create(context.TODO(), clonePod)
Expect(err).To(BeNil())
fmt.Printf("PVC %s is deleted\n", filepvc.Name)

By("PVC(block) Should be bound and Pod should be running")
Eventually(func() bool {
err := tests.DeployManagerObj.GetCrClient().Get(context.TODO(), types.NamespacedName{Name: blockpvc.Name, Namespace: blockpvc.Namespace}, blockpvc)
return err == nil && blockpvc.Status.Phase == k8sv1.ClaimBound
err := test.Get(context.TODO(), types.NamespacedName{Name: clonePvc.Name, Namespace: clonePvc.Namespace}, clonePvc)
return err == nil && clonePvc.Status.Phase == k8sv1.ClaimBound
}, timeout, interval).Should(BeTrue())
fmt.Printf("PVC %s is bound\n", blockpvc.Name)
fmt.Printf("Cloned PVC %s is bound\n", clonePvc.Name)

By("Restore Snapshot for block-pvc")
restorePvc = tests.GetPvc(size, pvc.Name+"snapshot", k8sv1.PersistentVolumeBlock, tests.StorageClass, "restore", "VolumeSnapshot")
err = test.Create(context.TODO(), restorePvc)
Expect(err).To(BeNil())
fmt.Printf("Snapshot %s is restored\n", restorePvc.Name)

restorePod = tests.GetSamplePod("restore-lvmblockpod", restorePvc.Name)
err = test.Create(context.TODO(), restorePod)
Expect(err).To(BeNil())

Eventually(func() bool {
err = tests.DeployManagerObj.GetCrClient().Get(context.TODO(), types.NamespacedName{Name: blockpod.Name, Namespace: blockpod.Namespace}, blockpod)
return err == nil && blockpod.Status.Phase == k8sv1.PodRunning
err := test.Get(context.TODO(), types.NamespacedName{Name: restorePvc.Name, Namespace: restorePvc.Namespace}, restorePvc)
return err == nil && restorePvc.Status.Phase == k8sv1.ClaimBound
}, timeout, interval).Should(BeTrue())
fmt.Printf("Pod %s is running\n", blockpod.Name)
fmt.Printf("Restored PVC %s is bound\n", restorePod.Name)

err = test.Delete(context.TODO(), clonePod)
Expect(err).To(BeNil())
fmt.Printf("Pod %s is deleted\n", clonePod.Name)

err = test.Delete(context.TODO(), clonePvc)
Expect(err).To(BeNil())
fmt.Printf("Clone PVC %s is deleted\n", clonePvc.Name)

err = test.Delete(context.TODO(), restorePod)
Expect(err).To(BeNil())
fmt.Printf("Pod %s is deleted\n", restorePod.Name)

err = test.Delete(context.TODO(), restorePvc)
Expect(err).To(BeNil())
fmt.Printf("Restored Snapshot %s is deleted\n", restorePvc.Name)

err = test.Delete(context.TODO(), snapshot)
Expect(err).To(BeNil())
fmt.Printf("Snapshot %s is deleted\n", snapshot.Name)

err = tests.DeployManagerObj.GetCrClient().Delete(context.TODO(), blockpod)
err = test.Delete(context.TODO(), pod)
Expect(err).To(BeNil())
fmt.Printf("Pod %s is deleted\n", blockpod.Name)
fmt.Printf("Pod %s is deleted\n", pod.Name)

err = tests.DeployManagerObj.GetCrClient().Delete(context.TODO(), blockpvc)
err = test.Delete(context.TODO(), pvc)
Expect(err).To(BeNil())
fmt.Printf("PVC %s is deleted\n", blockpvc.Name)
fmt.Printf("PVC %s is deleted\n", pvc.Name)
})
})

Expand Down
47 changes: 45 additions & 2 deletions e2e/testdata.go
View file
Original file line number Diff line number Diff line change
@@ -1,13 +1,14 @@
package e2e

import (
snapapi "github.com/kubernetes-csi/external-snapshotter/client/v4/apis/volumesnapshot/v1"
k8sv1 "k8s.io/api/core/v1"
"k8s.io/apimachinery/pkg/api/resource"
metav1 "k8s.io/apimachinery/pkg/apis/meta/v1"
)

// GetSamplePVC returns a sample pvc.
func GetSamplePVC(storageClass, quantity, name string, volumemode k8sv1.PersistentVolumeMode) *k8sv1.PersistentVolumeClaim {
func GetSamplePVC(storageClass, size, name string, volumemode k8sv1.PersistentVolumeMode) *k8sv1.PersistentVolumeClaim {
pvc := &k8sv1.PersistentVolumeClaim{
ObjectMeta: metav1.ObjectMeta{
Name: name,
Expand All @@ -19,7 +20,7 @@ func GetSamplePVC(storageClass, quantity, name string, volumemode k8sv1.Persiste
VolumeMode: &volumemode,
Resources: k8sv1.ResourceRequirements{
Requests: k8sv1.ResourceList{
k8sv1.ResourceStorage: resource.MustParse(quantity),
k8sv1.ResourceStorage: resource.MustParse(size),
},
},
},
Expand Down Expand Up @@ -61,3 +62,45 @@ func GetSamplePod(name, pvcName string) *k8sv1.Pod {
}
return pod
}

func GetSampleVolumeSnapshot(name string, storageClass string) *snapapi.VolumeSnapshot {
vs := &snapapi.VolumeSnapshot{
ObjectMeta: metav1.ObjectMeta{
// name = name of pvc + snapshot
Name: name + "snapshot",
Namespace: TestNamespace,
},
Spec: snapapi.VolumeSnapshotSpec{
VolumeSnapshotClassName: &storageClass,
Source: snapapi.VolumeSnapshotSource{
PersistentVolumeClaimName: &name,
},
},
}
return vs
}

// GetPvc returns restore or clone of the pvc based on the kind(kindName) provided.
func GetPvc(size, name string, volumemode k8sv1.PersistentVolumeMode, storageClass string, sourceType string, kindName string) *k8sv1.PersistentVolumeClaim {
pvc := &k8sv1.PersistentVolumeClaim{
ObjectMeta: metav1.ObjectMeta{
Name: name + sourceType,
Namespace: TestNamespace,
},
Spec: k8sv1.PersistentVolumeClaimSpec{
StorageClassName: &storageClass,
AccessModes: []k8sv1.PersistentVolumeAccessMode{k8sv1.ReadWriteOnce},
VolumeMode: &volumemode,
Resources: k8sv1.ResourceRequirements{
Requests: k8sv1.ResourceList{
k8sv1.ResourceStorage: resource.MustParse(size),
},
},
DataSource: &k8sv1.TypedLocalObjectReference{
Name: name,
Kind: kindName,
},
},
}
return pvc
}

0 comments on commit 4b332bc

Please sign in to comment.