Documentation ¶
Index ¶
- Constants
- Variables
- func CreateDeployment(ctx context.Context, tc *testingsdk.TestClient, ...) (*appsv1.Deployment, error)
- func CreateDisk(vcdClient *vcdsdk.Client, diskName string, diskSizeMB int64, ...) error
- func CreatePV(ctx context.Context, k8sClient *kubernetes.Clientset, ...) (*apiv1.PersistentVolume, error)
- func CreatePVC(ctx context.Context, k8sClient *kubernetes.Clientset, nameSpace string, ...) (*apiv1.PersistentVolumeClaim, error)
- func CreateStorageClass(ctx context.Context, k8sClient *kubernetes.Clientset, scName string, ...) (*stov1.StorageClass, error)
- func DeleteDisk(vcdClient *vcdsdk.Client, diskName string) error
- func DeletePV(ctx context.Context, k8sClient *kubernetes.Clientset, pvName string) error
- func DeletePVC(ctx context.Context, k8sClient *kubernetes.Clientset, nameSpace string, ...) error
- func DeleteStorageClass(ctx context.Context, k8sClient *kubernetes.Clientset, scName string) error
- func ExecCmdExample(client kubernetes.Interface, config *restclient.Config, nameSpace string, ...) (string, error)
- func FindFsTypeWithMountPath(executedOutput string, mountedPath string, fsType string) (bool, error)
- func GetDiskByNameViaVCD(vcdClient *vcdsdk.Client, diskName string) (disk *vcdtypes.Disk, err error)
- func GetPV(ctx context.Context, k8sClient *kubernetes.Clientset, pvName string) (*apiv1.PersistentVolume, error)
- func GetPVByNameViaRDE(pvName string, tc *testingsdk.TestClient, resourceType string) (bool, error)
- func GetPVC(ctx context.Context, k8sClient *kubernetes.Clientset, nameSpace string, ...) (*apiv1.PersistentVolumeClaim, error)
- func GetStorageClass(ctx context.Context, k8sClient *kubernetes.Clientset, scName string) (*stov1.StorageClass, error)
- func IncreasePVCSize(ctx context.Context, k8sClient *kubernetes.Clientset, nameSpace string, ...) (*apiv1.PersistentVolumeClaim, error)
- func RemoveDiskViaRDE(vcdClient *vcdsdk.Client, diskName string, clusterId string) error
- func ValidateDiskQuotaError(err error) bool
- func ValidateNoAttachedVM(vcdClient *vcdsdk.Client, disk *vcdtypes.Disk) error
- func VerifyDiskViaVCD(vcdClient *vcdsdk.Client, diskName string) (*vcdtypes.Disk, error)
- func WaitDiskDeleteViaVCD(vcdClient *vcdsdk.Client, diskName string) error
- func WaitForPVCDeleted(ctx context.Context, k8sClient *kubernetes.Clientset, nameSpace string, ...) (bool, error)
- func WaitForPVDeleted(ctx context.Context, k8sClient *kubernetes.Clientset, pvName string) (bool, error)
- func WaitForPvcReady(ctx context.Context, k8sClient *kubernetes.Clientset, nameSpace string, ...) error
- func WaitForPvcSizeUpdated(ctx context.Context, k8sClient *kubernetes.Clientset, nameSpace string, ...) error
Constants ¶
View Source
const ( CSIVersion = "1.3.0" MaxVCDUpdateRetries = 10 )
View Source
const ( NginxDeploymentVolumeName = "nginx-deployment-volume" InitContainerMountPath = "/init-container-msg-mount-path" DataMountPath = "/data" )
Variables ¶
View Source
var (
VcdResourceSetNotFound = errors.New("vcdResourceSet field not found in status->[csi] of RDE")
)
Functions ¶
func CreateDeployment ¶
func CreateDeployment(ctx context.Context, tc *testingsdk.TestClient, deploymentName, volumeName, containerImage, pvcRefName, mountPath, ns string) (*appsv1.Deployment, error)
func CreateDisk ¶
func CreatePV ¶
func CreatePV(ctx context.Context, k8sClient *kubernetes.Clientset, persistentVolumeName string, storageClass string, storageProfile string, storageSize string, reclaimPolicy apiv1.PersistentVolumeReclaimPolicy) (*apiv1.PersistentVolume, error)
func CreateStorageClass ¶
func CreateStorageClass(ctx context.Context, k8sClient *kubernetes.Clientset, scName string, reclaimPolicy apiv1.PersistentVolumeReclaimPolicy, storageProfile string, fsType string, allowVolumeExpansion bool, isMultiAZ string, storageClassZone string) (*stov1.StorageClass, error)
func DeleteStorageClass ¶
func ExecCmdExample ¶
func ExecCmdExample(client kubernetes.Interface, config *restclient.Config, nameSpace string, podName string, command []string) (string, error)
ExecCmdExample ExecCmd exec command on specific pod and wait the command's output.
func FindFsTypeWithMountPath ¶
func GetDiskByNameViaVCD ¶
func GetPV ¶
func GetPV(ctx context.Context, k8sClient *kubernetes.Clientset, pvName string) (*apiv1.PersistentVolume, error)
func GetPVByNameViaRDE ¶
func GetPVByNameViaRDE(pvName string, tc *testingsdk.TestClient, resourceType string) (bool, error)
func GetPVC ¶
func GetPVC(ctx context.Context, k8sClient *kubernetes.Clientset, nameSpace string, pvcName string) (*apiv1.PersistentVolumeClaim, error)
func GetStorageClass ¶
func GetStorageClass(ctx context.Context, k8sClient *kubernetes.Clientset, scName string) (*stov1.StorageClass, error)
func IncreasePVCSize ¶
func RemoveDiskViaRDE ¶
func ValidateDiskQuotaError ¶
func ValidateNoAttachedVM ¶
func VerifyDiskViaVCD ¶
func WaitDiskDeleteViaVCD ¶
func WaitForPVCDeleted ¶
func WaitForPVDeleted ¶
func WaitForPvcReady ¶
Types ¶
This section is empty.
Click to show internal directories.
Click to hide internal directories.