testsuites

type DataSource ¶

type DataSource struct {
	Kind string
	Name string
}

type DynamicallyProvisionedAccountWithTags ¶ added in v0.8.0

type DynamicallyProvisionedAccountWithTags struct {
	CSIDriver              driver.DynamicPVTestDriver
	Volumes                []VolumeDetails
	StorageClassParameters map[string]string
	Tags                   string
}

DynamicallyProvisionedAccountWithTags will provision required StorageClass(es), PVC(s) and Pod(s) Testing if the storage account contains tags

func (t *DynamicallyProvisionedAccountWithTags) Run(ctx context.Context, client clientset.Interface, namespace *v1.Namespace)

type DynamicallyProvisionedCmdVolumeTest ¶

type DynamicallyProvisionedCmdVolumeTest struct {
	CSIDriver              driver.DynamicPVTestDriver
	Pods                   []PodDetails
	StorageClassParameters map[string]string
}

DynamicallyProvisionedCmdVolumeTest will provision required StorageClass(es), PVC(s) and Pod(s) Waiting for the PV provisioner to create a new PV Testing if the Pod(s) Cmd is run with a 0 exit code

func (t *DynamicallyProvisionedCmdVolumeTest) Run(ctx context.Context, client clientset.Interface, namespace *v1.Namespace)

type DynamicallyProvisionedCollocatedPodTest ¶

type DynamicallyProvisionedCollocatedPodTest struct {
	CSIDriver              driver.DynamicPVTestDriver
	Pods                   []PodDetails
	ColocatePods           bool
	StorageClassParameters map[string]string
}

DynamicallyProvisionedCollocatedPodTest will provision required StorageClass(es), PVC(s) and Pod(s) Waiting for the PV provisioner to create a new PV Testing if multiple Pod(s) can write simultaneously

func (t *DynamicallyProvisionedCollocatedPodTest) Run(ctx context.Context, client clientset.Interface, namespace *v1.Namespace)

type DynamicallyProvisionedDeletePodTest ¶

type DynamicallyProvisionedDeletePodTest struct {
	CSIDriver              driver.DynamicPVTestDriver
	Pod                    PodDetails
	PodCheck               *PodExecCheck
	StorageClassParameters map[string]string
}

DynamicallyProvisionedDeletePodTest will provision required StorageClass and Deployment Testing if the Pod can write and read to mounted volumes Deleting a pod, and again testing if the Pod can write and read to mounted volumes

func (t *DynamicallyProvisionedDeletePodTest) Run(ctx context.Context, client clientset.Interface, namespace *v1.Namespace)

type DynamicallyProvisionedInlineVolumeTest ¶ added in v1.2.0

type DynamicallyProvisionedInlineVolumeTest struct {
	CSIDriver       driver.DynamicPVTestDriver
	Pods            []PodDetails
	SecretName      string
	ShareName       string
	Server          string
	ReadOnly        bool
	CSIInlineVolume bool
}

DynamicallyProvisionedInlineVolumeTest will provision required SecretName, ShareName Waiting for the PV provisioner to create an inline volume Testing if the Pod(s) Cmd is run with a 0 exit code

func (t *DynamicallyProvisionedInlineVolumeTest) Run(ctx context.Context, client clientset.Interface, namespace *v1.Namespace)

type DynamicallyProvisionedInvalidMountOptions ¶ added in v0.5.0

type DynamicallyProvisionedInvalidMountOptions struct {
	CSIDriver              driver.DynamicPVTestDriver
	Pods                   []PodDetails
	StorageClassParameters map[string]string
}

DynamicallyProvisionedInvalidMountOptions will provision a storage class with invalid mount options Testing if the Pod(s) Cmd is run with a 0 exit code

func (t *DynamicallyProvisionedInvalidMountOptions) Run(ctx context.Context, client clientset.Interface, namespace *v1.Namespace)

type DynamicallyProvisionedPodWithMultiplePVsTest ¶ added in v0.8.0

type DynamicallyProvisionedPodWithMultiplePVsTest struct {
	CSIDriver              driver.DynamicPVTestDriver
	Pods                   []PodDetails
	StorageClassParameters map[string]string
}

DynamicallyProvisionedPodWithMultiplePVsTest will provision one pod with multiple PVs Waiting for the PV provisioner to create a new PV Testing if the Pod(s) Cmd is run with a 0 exit code

func (t *DynamicallyProvisionedPodWithMultiplePVsTest) Run(ctx context.Context, client clientset.Interface, namespace *v1.Namespace)

type DynamicallyProvisionedReadOnlyVolumeTest ¶

type DynamicallyProvisionedReadOnlyVolumeTest struct {
	CSIDriver              driver.DynamicPVTestDriver
	Pods                   []PodDetails
	StorageClassParameters map[string]string
}

DynamicallyProvisionedReadOnlyVolumeTest will provision required StorageClass(es), PVC(s) and Pod(s) Waiting for the PV provisioner to create a new PV Testing that the Pod(s) cannot write to the volume when mounted

func (t *DynamicallyProvisionedReadOnlyVolumeTest) Run(ctx context.Context, client clientset.Interface, namespace *v1.Namespace)

type DynamicallyProvisionedReclaimPolicyTest ¶

type DynamicallyProvisionedReclaimPolicyTest struct {
	CSIDriver              driver.DynamicPVTestDriver
	Volumes                []VolumeDetails
	Azurefile              *azurefile.Driver
	StorageClassParameters map[string]string
}

DynamicallyProvisionedReclaimPolicyTest will provision required PV(s) and PVC(s) Testing the correct behavior for different reclaimPolicies

func (t *DynamicallyProvisionedReclaimPolicyTest) Run(ctx context.Context, client clientset.Interface, namespace *v1.Namespace)

type DynamicallyProvisionedResizeVolumeTest ¶ added in v0.5.0

type DynamicallyProvisionedResizeVolumeTest struct {
	CSIDriver              driver.DynamicPVTestDriver
	Pods                   []PodDetails
	StorageClassParameters map[string]string
}

DynamicallyProvisionedResizeVolumeTest will provision required StorageClass(es), PVC(s) and Pod(s) Waiting for the PV provisioner to resize the PV Testing if the PV is resized successfully.

func (t *DynamicallyProvisionedResizeVolumeTest) Run(ctx context.Context, client clientset.Interface, namespace *v1.Namespace)

type DynamicallyProvisionedRestartDriverTest ¶ added in v1.0.0

type DynamicallyProvisionedRestartDriverTest struct {
	CSIDriver              driver.DynamicPVTestDriver
	Pod                    PodDetails
	PodCheck               *PodExecCheck
	StorageClassParameters map[string]string
	RestartDriverFunc      func()
}

DynamicallyProvisionedRestartDriverTest will test to ensure that restarting driver doesn't affect pod mounting. It will mount a pod, restart the driver daemonset and ensure that the pod still has access to original volume.

func (t *DynamicallyProvisionedRestartDriverTest) Run(ctx context.Context, client clientset.Interface, namespace *v1.Namespace)

type DynamicallyProvisionedStatefulSetTest ¶ added in v0.10.0

type DynamicallyProvisionedStatefulSetTest struct {
	CSIDriver driver.DynamicPVTestDriver
	Pod       PodDetails
	PodCheck  *PodExecCheck
}

DynamicallyProvisionedStatefulSetTest will provision required StorageClass and StatefulSet Testing if the Pod can write and read to mounted volumes Deleting a pod, and again testing if the Pod can write and read to mounted volumes

func (t *DynamicallyProvisionedStatefulSetTest) Run(ctx context.Context, client clientset.Interface, namespace *v1.Namespace)

type DynamicallyProvisionedVolumeCloningTest ¶ added in v1.28.6

type DynamicallyProvisionedVolumeCloningTest struct {
	CSIDriver              driver.DynamicPVTestDriver
	Pod                    PodDetails
	PodWithClonedVolume    PodDetails
	ClonedVolumeSize       string
	StorageClassParameters map[string]string
}

DynamicallyProvisionedVolumeCloningTest will provision required StorageClass(es), PVC(s) and Pod(s) ClonedVolumeSize optional for when testing for cloned volume with different size to the original volume

func (t *DynamicallyProvisionedVolumeCloningTest) Run(ctx context.Context, client clientset.Interface, namespace *v1.Namespace)

type DynamicallyProvisionedVolumeSnapshotTest ¶ added in v0.8.0

type DynamicallyProvisionedVolumeSnapshotTest struct {
	CSIDriver                      driver.PVTestDriver
	Pod                            PodDetails
	ShouldOverwrite                bool
	ShouldRestore                  bool
	PodOverwrite                   PodDetails
	PodWithSnapshot                PodDetails
	StorageClassParameters         map[string]string
	SnapshotStorageClassParameters map[string]string
}

DynamicallyProvisionedVolumeSnapshotTest will provision required StorageClass(es),VolumeSnapshotClass(es), PVC(s) and Pod(s) Waiting for the PV provisioner to create a new PV Testing if the Pod(s) can write and read to mounted volumes Create a snapshot, validate whether it is ready to use. This test only supports a single volume

func (t *DynamicallyProvisionedVolumeSnapshotTest) Run(ctx context.Context, client clientset.Interface, restclient restclientset.Interface, namespace *v1.Namespace)

type DynamicallyProvisionedVolumeSubpathTester ¶ added in v1.2.0

type DynamicallyProvisionedVolumeSubpathTester struct {
	CSIDriver              driver.DynamicPVTestDriver
	Pods                   []PodDetails
	StorageClassParameters map[string]string
}

DynamicallyProvisionedCmdVolumeTest will provision required StorageClass(es), PVC(s) and Pod(s) Waiting for the PV provisioner to create a new PV Testing if the Pod(s) Cmd is run with a 0 exit code

func (t *DynamicallyProvisionedVolumeSubpathTester) Run(ctx context.Context, client clientset.Interface, namespace *v1.Namespace)

type DynamicallyProvisionedVolumeUnmountTest ¶ added in v1.25.0

type DynamicallyProvisionedVolumeUnmountTest struct {
	CSIDriver              driver.DynamicPVTestDriver
	Azurefile              *azurefile.Driver
	Pod                    PodDetails
	PodCheck               *PodExecCheck
	StorageClassParameters map[string]string
}

DynamicallyProvisionedVolumeUnmountTest will provision required StorageClass and Deployment Testing if the Pod can write and read to mounted volumes Delete the volume and check whether pod could be terminated successfully

func (t *DynamicallyProvisionedVolumeUnmountTest) Run(ctx context.Context, client clientset.Interface, namespace *v1.Namespace)

type PodDetails ¶

type PodDetails struct {
	Cmd          string
	Volumes      []VolumeDetails
	IsWindows    bool
	WinServerVer string
	UseCMD       bool
}

func (pod *PodDetails) SetupDeployment(ctx context.Context, client clientset.Interface, namespace *v1.Namespace, replicas int32, csiDriver driver.DynamicPVTestDriver, storageClassParameters map[string]string) (*TestDeployment, []func(ctx context.Context), string)

func (pod *PodDetails) SetupStatefulset(ctx context.Context, client clientset.Interface, namespace *v1.Namespace, csiDriver driver.DynamicPVTestDriver) (*TestStatefulset, []func(ctx context.Context))

func (pod *PodDetails) SetupWithCSIInlineVolumes(client clientset.Interface, namespace *v1.Namespace, secretName, shareName, server string, readOnly bool) (*TestPod, []func())

func (pod *PodDetails) SetupWithDynamicMultipleVolumes(ctx context.Context, client clientset.Interface, namespace *v1.Namespace, csiDriver driver.DynamicPVTestDriver, storageClassParameters map[string]string) (*TestPod, []func(ctx context.Context))

func (pod *PodDetails) SetupWithDynamicVolumes(ctx context.Context, client clientset.Interface, namespace *v1.Namespace, csiDriver driver.DynamicPVTestDriver, storageClassParameters map[string]string) (*TestPod, []func(ctx context.Context))

func (pod *PodDetails) SetupWithDynamicVolumesWithSubpath(ctx context.Context, client clientset.Interface, namespace *v1.Namespace, csiDriver driver.DynamicPVTestDriver, storageClassParameters map[string]string) (*TestPod, []func(ctx context.Context))

func (pod *PodDetails) SetupWithInlineVolumes(client clientset.Interface, namespace *v1.Namespace, secretName, shareName string, readOnly bool) (*TestPod, []func())

func (pod *PodDetails) SetupWithPreProvisionedVolumes(ctx context.Context, client clientset.Interface, namespace *v1.Namespace, csiDriver driver.PreProvisionedVolumeTestDriver) (*TestPod, []func(ctx context.Context))

type PodExecCheck ¶

type PodExecCheck struct {
	Cmd            []string
	ExpectedString string
}

type PreProvisionedExistingCredentialsTest ¶ added in v0.7.0

type PreProvisionedExistingCredentialsTest struct {
	CSIDriver driver.PreProvisionedVolumeTestDriver
	Pods      []PodDetails
	Azurefile *azurefile.Driver
}

PreProvisionedExistingCredentialsTest will provision required StorageClass(es), PVC(s) and Pod(s) Testing that the Pod(s) can be created successfully with existing credentials in k8s cluster

func (t *PreProvisionedExistingCredentialsTest) Run(ctx context.Context, client clientset.Interface, namespace *v1.Namespace)

type PreProvisionedMultiplePods ¶ added in v0.9.0

type PreProvisionedMultiplePods struct {
	CSIDriver driver.PreProvisionedVolumeTestDriver
	Pods      []PodDetails
}

PreProvisionedMultiplePods will provision required PV(s), PVC(s) and Pod(s) Testing that the Pod(s) cannot write to the volume when mounted

func (t *PreProvisionedMultiplePods) Run(ctx context.Context, client clientset.Interface, namespace *v1.Namespace)

type PreProvisionedProvidedCredentiasTest ¶ added in v0.7.0

type PreProvisionedProvidedCredentiasTest struct {
	CSIDriver driver.PreProvisionedVolumeTestDriver
	Pods      []PodDetails
	Azurefile *azurefile.Driver
}

PreProvisionedProvidedCredentiasTest will provision required PV(s), PVC(s) and Pod(s) Testing that the Pod(s) can be created successfully with provided storage account name and key(or sastoken)

func (t *PreProvisionedProvidedCredentiasTest) Run(ctx context.Context, client clientset.Interface, namespace *v1.Namespace)

type PreProvisionedReadOnlyVolumeTest ¶

type PreProvisionedReadOnlyVolumeTest struct {
	CSIDriver driver.PreProvisionedVolumeTestDriver
	Pods      []PodDetails
}

PreProvisionedReadOnlyVolumeTest will provision required PV(s), PVC(s) and Pod(s) Testing that the Pod(s) cannot write to the volume when mounted

func (t *PreProvisionedReadOnlyVolumeTest) Run(ctx context.Context, client clientset.Interface, namespace *v1.Namespace)

type PreProvisionedReclaimPolicyTest ¶

type PreProvisionedReclaimPolicyTest struct {
	CSIDriver driver.PreProvisionedVolumeTestDriver
	Volumes   []VolumeDetails
}

PreProvisionedReclaimPolicyTest will provision required PV(s) and PVC(s) Testing the correct behavior for different reclaimPolicies

func (t *PreProvisionedReclaimPolicyTest) Run(ctx context.Context, client clientset.Interface, namespace *v1.Namespace)

type TestDeployment ¶

type TestDeployment struct {
	// contains filtered or unexported fields
}

func NewTestDeployment(c clientset.Interface, ns *v1.Namespace, replicas int32, command string, pvc *v1.PersistentVolumeClaim, volumeName, mountPath string, readOnly, isWindows bool, winServerVer string) *TestDeployment

func (t *TestDeployment) Cleanup(ctx context.Context)

func (t *TestDeployment) Create(ctx context.Context)

func (t *TestDeployment) DeletePodAndWait(ctx context.Context)

func (t *TestDeployment) Logs(ctx context.Context) ([]byte, error)

func (t *TestDeployment) PollForStringInPodsExec(command []string, expectedString string)

func (t *TestDeployment) WaitForPodReady(ctx context.Context)

type TestPersistentVolumeClaim ¶

type TestPersistentVolumeClaim struct {
	// contains filtered or unexported fields
}

func NewTestPersistentVolumeClaim(c clientset.Interface, ns *v1.Namespace, claimSize string, volumeMode VolumeMode, sc *storagev1.StorageClass) *TestPersistentVolumeClaim

func NewTestPersistentVolumeClaimWithDataSource(c clientset.Interface, ns *v1.Namespace, claimSize string, volumeMode VolumeMode, sc *storagev1.StorageClass, dataSource *v1.TypedLocalObjectReference) *TestPersistentVolumeClaim

func (t *TestPersistentVolumeClaim) Cleanup(ctx context.Context)

func (t *TestPersistentVolumeClaim) Create(ctx context.Context)

func (t *TestPersistentVolumeClaim) DeleteBackingVolume(ctx context.Context, azfile *azurefile.Driver)

func (t *TestPersistentVolumeClaim) DeleteBoundPersistentVolume(ctx context.Context)

func (t *TestPersistentVolumeClaim) ReclaimPolicy() v1.PersistentVolumeReclaimPolicy

func (t *TestPersistentVolumeClaim) ValidateProvisionedPersistentVolume(ctx context.Context)

func (t *TestPersistentVolumeClaim) WaitForBound(ctx context.Context) v1.PersistentVolumeClaim

func (t *TestPersistentVolumeClaim) WaitForPersistentVolumePhase(ctx context.Context, phase v1.PersistentVolumePhase)

type TestPod ¶

type TestPod struct {
	// contains filtered or unexported fields
}

func NewTestPod(c clientset.Interface, ns *v1.Namespace, command string, isWindows bool, winServerVer string) *TestPod

func (t *TestPod) Cleanup(ctx context.Context)

func (t *TestPod) Create(ctx context.Context)

func (t *TestPod) Logs(ctx context.Context) ([]byte, error)

func (t *TestPod) SetAffinity(affinity *v1.Affinity)

func (t *TestPod) SetLabel(labels map[string]string)

func (t *TestPod) SetNodeSelector(nodeSelector map[string]string)

func (t *TestPod) SetupCSIInlineVolume(name, mountPath, secretName, shareName, server string, readOnly bool)

func (t *TestPod) SetupInlineVolume(name, mountPath, secretName, shareName string, readOnly bool)

func (t *TestPod) SetupRawBlockVolume(pvc *v1.PersistentVolumeClaim, name, devicePath string)

func (t *TestPod) SetupVolume(pvc *v1.PersistentVolumeClaim, name, mountPath string, readOnly bool)

func (t *TestPod) SetupVolumeMountWithSubpath(pvc *v1.PersistentVolumeClaim, name, mountPath string, subpath string, readOnly bool)

func (t *TestPod) WaitForFailedMountError(ctx context.Context)

func (t *TestPod) WaitForFailure(ctx context.Context)

func (t *TestPod) WaitForRunning(ctx context.Context)

func (t *TestPod) WaitForSuccess(ctx context.Context)

type TestPreProvisionedPersistentVolume ¶

type TestPreProvisionedPersistentVolume struct {
	// contains filtered or unexported fields
}

func NewTestPreProvisionedPersistentVolume(c clientset.Interface, pv *v1.PersistentVolume) *TestPreProvisionedPersistentVolume

func (pv *TestPreProvisionedPersistentVolume) Create(ctx context.Context) v1.PersistentVolume

type TestSecret ¶ added in v0.7.0

type TestSecret struct {
	// contains filtered or unexported fields
}

func NewTestSecret(c clientset.Interface, ns *v1.Namespace, name string, data map[string]string) *TestSecret

func (t *TestSecret) Cleanup(ctx context.Context)

func (t *TestSecret) Create(ctx context.Context)

type TestStatefulset ¶ added in v0.10.0

type TestStatefulset struct {
	// contains filtered or unexported fields
}

func NewTestStatefulset(c clientset.Interface, ns *v1.Namespace, command string, pvc *v1.PersistentVolumeClaim, volumeName, mountPath string, readOnly, isWindows, useCMD bool, winServerVer string) *TestStatefulset

func (t *TestStatefulset) Cleanup(ctx context.Context)

func (t *TestStatefulset) Create(ctx context.Context)

func (t *TestStatefulset) DeletePodAndWait(ctx context.Context)

func (t *TestStatefulset) Logs(ctx context.Context) ([]byte, error)

func (t *TestStatefulset) PollForStringInPodsExec(command []string, expectedString string)

func (t *TestStatefulset) WaitForPodReady(ctx context.Context)

type TestStorageClass ¶

type TestStorageClass struct {
	// contains filtered or unexported fields
}

func NewTestStorageClass(c clientset.Interface, ns *v1.Namespace, sc *storagev1.StorageClass) *TestStorageClass

func (t *TestStorageClass) Cleanup(ctx context.Context)

func (t *TestStorageClass) Create(ctx context.Context) storagev1.StorageClass

type TestVolumeSnapshotClass ¶

type TestVolumeSnapshotClass struct {
	// contains filtered or unexported fields
}

func CreateVolumeSnapshotClass(ctx context.Context, client restclientset.Interface, namespace *v1.Namespace, csiDriver driver.VolumeSnapshotTestDriver) (*TestVolumeSnapshotClass, func())

func NewTestVolumeSnapshotClass(c restclientset.Interface, ns *v1.Namespace, vsc *snapshotv1.VolumeSnapshotClass) *TestVolumeSnapshotClass

func (t *TestVolumeSnapshotClass) Cleanup()

func (t *TestVolumeSnapshotClass) Create(ctx context.Context)

func (t *TestVolumeSnapshotClass) CreateSnapshot(ctx context.Context, pvc *v1.PersistentVolumeClaim) *snapshotv1.VolumeSnapshot

func (t *TestVolumeSnapshotClass) DeleteSnapshot(ctx context.Context, vs *snapshotv1.VolumeSnapshot)

func (t *TestVolumeSnapshotClass) ReadyToUse(ctx context.Context, snapshot *snapshotv1.VolumeSnapshot)

type VolumeDetails ¶

type VolumeDetails struct {
	VolumeType            string
	FSType                string
	Encrypted             bool
	MountOptions          []string
	ClaimSize             string
	ReclaimPolicy         *v1.PersistentVolumeReclaimPolicy
	VolumeBindingMode     *storagev1.VolumeBindingMode
	AllowedTopologyValues []string
	VolumeMode            VolumeMode
	VolumeMount           VolumeMountDetails
	VolumeDevice          VolumeDeviceDetails
	// Optional, used with pre-provisioned volumes
	VolumeID string
	// Optional, used with PVCs created from snapshots
	DataSource *DataSource
	// Optional, used with specified StorageClass
	StorageClass       *storagev1.StorageClass
	ShareName          string
	NodeStageSecretRef string
}

func (volume *VolumeDetails) CreateStorageClass(ctx context.Context, client clientset.Interface, namespace *v1.Namespace, csiDriver driver.DynamicPVTestDriver, storageClassParameters map[string]string) (*TestStorageClass, func(ctx context.Context))

func (volume *VolumeDetails) SetupDynamicPersistentVolumeClaim(ctx context.Context, client clientset.Interface, namespace *v1.Namespace, csiDriver driver.DynamicPVTestDriver, storageClassParameters map[string]string) (*TestPersistentVolumeClaim, []func(ctx context.Context))

func (volume *VolumeDetails) SetupPreProvisionedPersistentVolumeClaim(ctx context.Context, client clientset.Interface, namespace *v1.Namespace, csiDriver driver.PreProvisionedVolumeTestDriver) (*TestPersistentVolumeClaim, []func(ctx context.Context))

type VolumeDeviceDetails ¶

type VolumeDeviceDetails struct {
	NameGenerate string
	DevicePath   string
}

type VolumeMode ¶

type VolumeMode int

const (
	FileSystem VolumeMode = iota
	Block
)

type VolumeMountDetails ¶

type VolumeMountDetails struct {
	NameGenerate      string
	MountPathGenerate string
	ReadOnly          bool
}