testsuites

type DataSource ¶

type DataSource struct {
	Kind string
	Name string
}

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
	ContainerName string
	ReadOnly      bool
}

DynamicallyProvisionedInlineVolumeTest will provision required SecretName, ContainerName 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.7.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.7.0

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

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
	Driver                 *blob.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.11.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.17.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 DynamicallyProvisionedVolumeCloningTest ¶ added in v1.23.2

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 DynamicallyProvisionedVolumeUnmountTest ¶ added in v1.20.0

type DynamicallyProvisionedVolumeUnmountTest struct {
	CSIDriver              driver.DynamicPVTestDriver
	Driver                 *blob.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
}

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

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

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

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

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

type PodExecCheck ¶

type PodExecCheck struct {
	Cmd            []string
	ExpectedString string
}

type PreProvisionedExistingCredentialsTest ¶ added in v0.5.0

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

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 PreProvisionedKeyVaultTest ¶ added in v1.16.0

type PreProvisionedKeyVaultTest struct {
	CSIDriver driver.PreProvisionedVolumeTestDriver
	Pods      []PodDetails
	Driver    *blob.Driver
}

PreProvisionedKeyVaultTest will provision required PV(s), PVC(s) and Pod(s) Testing that the Pod(s) can be created successfully with provided Key Vault which is used to store storage account name and key

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

type PreProvisionedMultiplePods ¶ added in v1.2.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.5.0

type PreProvisionedProvidedCredentiasTest struct {
	CSIDriver driver.PreProvisionedVolumeTestDriver
	Pods      []PodDetails
	Driver    *blob.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 PreProvisionedSASTokenTest ¶ added in v1.16.0

type PreProvisionedSASTokenTest struct {
	CSIDriver driver.PreProvisionedVolumeTestDriver
	Pods      []PodDetails
	Driver    *blob.Driver
}

PreProvisionedSASTokenTest will provision required PV(s), PVC(s) and Pod(s) Testing that the Pod(s) can be created successfully with provided Key Vault which is used to store storage SAS token

func (t *PreProvisionedSASTokenTest) 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, command string, pvc *v1.PersistentVolumeClaim, volumeName, mountPath string, readOnly bool) *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) Exec(command []string, expectedString string)

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 *blob.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) *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) SetNodeSelector(nodeSelector map[string]string)

func (t *TestPod) SetupInlineVolume(name, mountPath, secretName, containerName 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) 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.5.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 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 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
	NodeStageSecretRef string
	Attrib             map[string]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(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
}