-
Notifications
You must be signed in to change notification settings - Fork 40
Commit
This commit does not belong to any branch on this repository, and may belong to a fork outside of the repository.
test: added test to validate the LVMO resources
This test validates all the resources created by LVMO Signed-off-by: riya-singhal31 <[email protected]>
- Loading branch information
1 parent
2a5c5cd
commit 27fe12b
Showing
5 changed files
with
185 additions
and
6 deletions.
There are no files selected for viewing
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
| Original file line number | Diff line number | Diff line change |
|---|---|---|
| @@ -0,0 +1,175 @@ | ||
| package e2e | ||
|
|
||
| import ( | ||
| "context" | ||
| "time" | ||
|
|
||
| . "github.com/onsi/gomega" | ||
| lvmv1alpha1 "github.com/red-hat-storage/lvm-operator/api/v1alpha1" | ||
| appsv1 "k8s.io/api/apps/v1" | ||
| storagev1 "k8s.io/api/storage/v1" | ||
| "k8s.io/apimachinery/pkg/types" | ||
| ) | ||
|
|
||
| const ( | ||
| timeout = time.Minute * 15 | ||
| interval = time.Second * 30 | ||
| lvmVolumeGroupName = "vg1" | ||
| storageClassName = "odf-lvm-vg1" | ||
| csiDriverName = "topolvm.cybozu.com" | ||
| topolvmNodeDaemonSetName = "topolvm-node" | ||
| topolvmCtrlDeploymentName = "topolvm-controller" | ||
| vgManagerDaemonsetName = "vg-manager" | ||
| ) | ||
|
|
||
| // function to validate LVMVolume group. | ||
| func ValidateLVMvg() error { | ||
| lvmVG := lvmv1alpha1.LVMVolumeGroup{} | ||
|
|
||
| Eventually(func() bool { | ||
| debug("%s \n", "Starting function - vg") | ||
| err := DeployManagerObj.GetCrClient().Get(context.TODO(), types.NamespacedName{Name: lvmVolumeGroupName, Namespace: InstallNamespace}, &lvmVG) | ||
| if err != nil { | ||
| debug("LVMVolumeGroup: %s\n", err.Error()) | ||
| } | ||
| return err == nil | ||
| }, timeout, interval).Should(BeTrue()) | ||
|
|
||
| debug("VG found\n") | ||
| return nil | ||
| } | ||
|
|
||
| // function to validate storage class. | ||
| func ValidateStorageClass() error { | ||
| sc := storagev1.StorageClass{} | ||
|
|
||
| Eventually(func() bool { | ||
| debug("%s\n", "Starting function - sc") | ||
| err := DeployManagerObj.GetCrClient().Get(context.TODO(), types.NamespacedName{Name: storageClassName}, &sc) | ||
| if err != nil { | ||
| debug("StorageClass : %s\n", err.Error()) | ||
| } | ||
| return err == nil | ||
| }, timeout, interval).Should(BeTrue()) | ||
|
|
||
| debug("SC found\n") | ||
| return nil | ||
| } | ||
|
|
||
| // function to validate CSI Driver. | ||
| func ValidateCSIDriver() error { | ||
| cd := storagev1.CSIDriver{} | ||
|
|
||
| Eventually(func() bool { | ||
| debug("%s\n", "Starting function - cd") | ||
| err := DeployManagerObj.GetCrClient().Get(context.TODO(), types.NamespacedName{Name: csiDriverName, Namespace: InstallNamespace}, &cd) | ||
| if err != nil { | ||
| debug("CSIDriver : %s\n", err.Error()) | ||
| } | ||
| return err == nil | ||
| }, timeout, interval).Should(BeTrue()) | ||
|
|
||
| debug("CSI Driver found\n") | ||
| return nil | ||
| } | ||
|
|
||
| // function to validate TopoLVM node. | ||
| func ValidateTopolvmNode() error { | ||
| ds := appsv1.DaemonSet{} | ||
| Eventually(func() bool { | ||
| debug("%s\n", "Starting function - topolvmnode") | ||
| err := DeployManagerObj.GetCrClient().Get(context.TODO(), types.NamespacedName{Name: topolvmNodeDaemonSetName, Namespace: InstallNamespace}, &ds) | ||
| if err != nil { | ||
| debug("topolvmNode : %s\n", err.Error()) | ||
| return false | ||
| } | ||
| return ds.Status.DesiredNumberScheduled == ds.Status.NumberReady | ||
| }, timeout, interval).Should(BeTrue()) | ||
| debug("TopoLVM node found\n") | ||
|
|
||
| /* // checking for the ready status | ||
| Eventually(func() bool { | ||
| err := DeployManagerObj.GetCrClient().Get(context.TODO(), types.NamespacedName{Name: topolvmNodeDaemonSetName, Namespace: InstallNamespace}, &ds) | ||
| if err != nil { | ||
| debug("topolvmNode : %s", err.Error()) | ||
| return | ||
| } | ||
| return ds.Status.DesiredNumberScheduled == ds.Status.NumberReady | ||
| }, timeout, interval).Should(BeTrue()) | ||
| debug("Status is ready\n") */ | ||
|
|
||
| return nil | ||
| } | ||
|
|
||
| // function to validate vg manager resource. | ||
| func ValidateVGManager() error { | ||
| ds := appsv1.DaemonSet{} | ||
|
|
||
| Eventually(func() bool { | ||
| debug("%s\n", "Starting function - vgmanager") | ||
| err := DeployManagerObj.GetCrClient().Get(context.TODO(), types.NamespacedName{Name: vgManagerDaemonsetName, Namespace: InstallNamespace}, &ds) | ||
| if err != nil { | ||
| debug("vgmanager : %s\n", err.Error()) | ||
| } | ||
| return err == nil | ||
| }, timeout, interval).Should(BeTrue()) | ||
| debug("VG manager found\n") | ||
|
|
||
| return nil | ||
| } | ||
|
|
||
| // function to validate TopoLVM Deployment. | ||
| func ValidateTopolvmController() error { | ||
| dep := appsv1.Deployment{} | ||
|
|
||
| Eventually(func() bool { | ||
| debug("%s\n", "Starting function - topolvmcontroller") | ||
| err := DeployManagerObj.GetCrClient().Get(context.TODO(), types.NamespacedName{Name: topolvmCtrlDeploymentName, Namespace: InstallNamespace}, &dep) | ||
| if err != nil { | ||
| debug("topolvmcontroller : %s\n", err.Error()) | ||
| } | ||
| return err == nil | ||
| }, timeout, interval).Should(BeTrue()) | ||
|
|
||
| debug("depoloyment found\n") | ||
| return nil | ||
| } | ||
|
|
||
| // Validate all the resources created by LVMO. | ||
| func ValidateResources() error { | ||
|
|
||
| // Validate CSI Driver | ||
| err := ValidateCSIDriver() | ||
| if err != nil { | ||
| return err | ||
| } | ||
|
|
||
| //Validate TopoLVM Controller | ||
| err = ValidateTopolvmController() | ||
| if err != nil { | ||
| return err | ||
| } | ||
|
|
||
| // Validate VG Manager Daemonset | ||
| err = ValidateVGManager() | ||
| if err != nil { | ||
| return err | ||
| } | ||
| // Validate LVMVg | ||
| err = ValidateLVMvg() | ||
| if err != nil { | ||
| return err | ||
| } | ||
|
|
||
| // Validate Topolvm node | ||
| err = ValidateTopolvmNode() | ||
| if err != nil { | ||
| return err | ||
| } | ||
| // Validate Storage class | ||
| err = ValidateStorageClass() | ||
| if err != nil { | ||
| return err | ||
| } | ||
| return nil | ||
| } |
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters