testsuites

type DataSource ¶ added in v0.3.0

type DataSource struct {
	Name string
}

type DynamicallyProvisionedCmdVolumeTest ¶ added in v0.3.0

type DynamicallyProvisionedCmdVolumeTest struct {
	CSIDriver    driver.DynamicPVTestDriver
	Pods         []PodDetails
	ValidateFunc func()
}

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(client clientset.Interface, namespace *v1.Namespace)

type DynamicallyProvisionedCollocatedPodTest ¶

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

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(client clientset.Interface, namespace *v1.Namespace)

type DynamicallyProvisionedDeletePodTest ¶

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

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(client clientset.Interface, namespace *v1.Namespace)

type DynamicallyProvisionedMultiAttachTest ¶ added in v1.25.0

type DynamicallyProvisionedMultiAttachTest struct {
	CSIDriver  driver.DynamicPVTestDriver
	Pods       []PodDetails
	VolumeMode VolumeMode
	AccessMode v1.PersistentVolumeAccessMode
	VolumeType string
	RunningPod bool
	PendingPVC bool
}

func (t *DynamicallyProvisionedMultiAttachTest) Run(client clientset.Interface, namespace *v1.Namespace)

type DynamicallyProvisionedReadOnlyVolumeTest ¶

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

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(client clientset.Interface, namespace *v1.Namespace)

type DynamicallyProvisionedReclaimPolicyTest ¶

type DynamicallyProvisionedReclaimPolicyTest struct {
	CSIDriver driver.DynamicPVTestDriver
	Volumes   []VolumeDetails
	Cloud     cloud.Cloud
}

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

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

type DynamicallyProvisionedResizeVolumeTest ¶ added in v0.9.0

type DynamicallyProvisionedResizeVolumeTest struct {
	CSIDriver driver.DynamicPVTestDriver
	Pod       PodDetails
}

DynamicallyProvisionedResizeVolumeTest will provision required StorageClass(es), PVC(s) and Pod(s) Waiting for the PV provisioner to create a new PV Update pvc storage size Waiting for new PVC and PV to be ready And finally attach pvc to the pod and wait for pod to be ready.

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

type DynamicallyProvisionedTopologyAwareVolumeTest ¶

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

DynamicallyProvisionedTopologyAwareVolumeTest 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) can write and read to mounted volumes Validate PVs have expected PV nodeAffinity

func (t *DynamicallyProvisionedTopologyAwareVolumeTest) Run(client clientset.Interface, namespace *v1.Namespace)

type DynamicallyProvisionedVolumeSnapshotTest ¶ added in v0.3.0

type DynamicallyProvisionedVolumeSnapshotTest struct {
	CSIDriver    driver.PVTestDriver
	Pod          PodDetails
	RestoredPod  PodDetails
	Parameters   map[string]string
	ValidateFunc func(*volumesnapshotv1.VolumeSnapshot)
}

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 the data is still on the disk, and then write and read to it again And finally delete the snapshot This test only supports a single volume

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

type FormatOptionTest ¶ added in v1.24.0

type FormatOptionTest struct {
	CreateVolumeParameters map[string]string
}

FormatOptionTest will provision required StorageClass(es), PVC(s) and Pod(s) in order to test that volumes with a specified custom format options will mount and are able to be later resized.

func (t *FormatOptionTest) Run(client clientset.Interface, namespace *v1.Namespace, ebsDriver driver.PVTestDriver)

type ModifyTestType ¶ added in v1.29.0

type ModifyTestType int64

const (
	VolumeModifierForK8s ModifyTestType = iota
	ExternalResizer
)

type ModifyVolumeTest ¶ added in v1.26.0

type ModifyVolumeTest struct {
	CreateVolumeParameters                map[string]string
	ModifyVolumeAnnotations               map[string]string
	ShouldResizeVolume                    bool
	ShouldTestInvalidModificationRecovery bool
}

ModifyVolumeTest will provision pod with attached volume, and test that modifying its pvc will modify the associated pv.

func (modifyVolumeTest *ModifyVolumeTest) Run(c clientset.Interface, ns *v1.Namespace, ebsDriver driver.PVTestDriver, testType ModifyTestType)

type PodDetails ¶

type PodDetails struct {
	Cmd     string
	Volumes []VolumeDetails
}

func (pod *PodDetails) SetupDeployment(client clientset.Interface, namespace *v1.Namespace, csiDriver driver.DynamicPVTestDriver) (*TestDeployment, []func())

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

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

type PodExecCheck ¶

type PodExecCheck struct {
	Cmd            []string
	ExpectedString string
}

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(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(client clientset.Interface, namespace *v1.Namespace)

type PreProvisionedVolumeSnapshotTest ¶ added in v0.9.0

type PreProvisionedVolumeSnapshotTest struct {
	CSIDriver driver.PVTestDriver
	Pod       PodDetails
}

func (t *PreProvisionedVolumeSnapshotTest) Run(client clientset.Interface, restclient k8srestclient.Interface, namespace *v1.Namespace, snapshotId string)

type PreProvisionedVolumeTest ¶

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

PreProvisionedVolumeTest will provision required PV(s), PVC(s) and Pod(s) Testing if the Pod(s) can write and read to mounted volumes

func (t *PreProvisionedVolumeTest) Run(client clientset.Interface, namespace *v1.Namespace)

type StaticallyProvisionedMultiAttachTest ¶ added in v1.25.0

type StaticallyProvisionedMultiAttachTest struct {
	CSIDriver  driver.PreProvisionedVolumeTestDriver
	Pods       []PodDetails
	AccessMode v1.PersistentVolumeAccessMode
	VolumeMode v1.PersistentVolumeMode
	VolumeType string
	RunningPod bool
	PendingPVC bool
	VolumeID   string
}

func (t *StaticallyProvisionedMultiAttachTest) Run(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()

func (t *TestDeployment) Create()

func (t *TestDeployment) DeletePodAndWait()

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

func (t *TestDeployment) Logs() ([]byte, error)

func (t *TestDeployment) WaitForPodReady()

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, accessMode v1.PersistentVolumeAccessMode) *TestPersistentVolumeClaim

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

func (t *TestPersistentVolumeClaim) Cleanup()

func (t *TestPersistentVolumeClaim) Create()

func (t *TestPersistentVolumeClaim) DeleteBackingVolume(cloud awscloud.Cloud)

func (t *TestPersistentVolumeClaim) DeleteBoundPersistentVolume()

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

func (t *TestPersistentVolumeClaim) ValidateProvisionedPersistentVolume()

func (t *TestPersistentVolumeClaim) WaitForBound() v1.PersistentVolumeClaim

func (t *TestPersistentVolumeClaim) WaitForPersistentVolumePhase(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()

func (t *TestPod) Create()

func (t *TestPod) Logs() ([]byte, error)

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

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) WaitForFailure()

func (t *TestPod) WaitForRunning()

func (t *TestPod) WaitForSuccess()

type TestPreProvisionedPersistentVolume ¶

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

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

func (pv *TestPreProvisionedPersistentVolume) Create() v1.PersistentVolume

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()

func (t *TestStorageClass) Create() storagev1.StorageClass

type TestVolumeSnapshotClass ¶ added in v0.3.0

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

func CreateVolumeSnapshotClass(client restclientset.Interface, namespace *v1.Namespace, csiDriver driver.VolumeSnapshotTestDriver, vscParameters map[string]string) (*TestVolumeSnapshotClass, func())

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

func (t *TestVolumeSnapshotClass) Cleanup()

func (t *TestVolumeSnapshotClass) Create()

func (t *TestVolumeSnapshotClass) CreateSnapshot(pvc *v1.PersistentVolumeClaim) *volumesnapshotv1.VolumeSnapshot

func (t *TestVolumeSnapshotClass) CreateStaticVolumeSnapshot(vsc *volumesnapshotv1.VolumeSnapshotContent) *volumesnapshotv1.VolumeSnapshot

func (t *TestVolumeSnapshotClass) CreateStaticVolumeSnapshotContent(snapshotId string) *volumesnapshotv1.VolumeSnapshotContent

func (t *TestVolumeSnapshotClass) DeleteSnapshot(vs *volumesnapshotv1.VolumeSnapshot)

func (t *TestVolumeSnapshotClass) DeleteVolumeSnapshotContent(vsc *volumesnapshotv1.VolumeSnapshotContent)

func (t *TestVolumeSnapshotClass) ReadyToUse(snapshot *volumesnapshotv1.VolumeSnapshot)

func (t *TestVolumeSnapshotClass) UpdateStaticVolumeSnapshotContent(volumeSnapshot *volumesnapshotv1.VolumeSnapshot, volumeSnapshotContent *volumesnapshotv1.VolumeSnapshotContent)

type VolumeDetails ¶

type VolumeDetails struct {
	MountOptions               []string
	ClaimSize                  string
	ReclaimPolicy              *v1.PersistentVolumeReclaimPolicy
	AllowVolumeExpansion       *bool
	VolumeBindingMode          *storagev1.VolumeBindingMode
	AccessMode                 v1.PersistentVolumeAccessMode
	AllowedTopologyValues      []string
	VolumeMode                 VolumeMode
	VolumeMount                VolumeMountDetails
	VolumeDevice               VolumeDeviceDetails
	CreateVolumeParameters     map[string]string // Optional, used when dynamically-provisioned volumes
	VolumeID                   string            // Optional, used with pre-provisioned volumes
	PreProvisionedVolumeFsType string            // Optional, used with pre-provisioned volumes
	DataSource                 *DataSource       // Optional, used with PVCs created from snapshots
}

func CreateVolumeDetails(createVolumeParameters map[string]string, volumeSize string) *VolumeDetails

func (volume *VolumeDetails) SetupDynamicPersistentVolumeClaim(client clientset.Interface, namespace *v1.Namespace, csiDriver driver.DynamicPVTestDriver) (*TestPersistentVolumeClaim, []func())

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

type VolumeDeviceDetails ¶ added in v0.3.0

type VolumeDeviceDetails struct {
	NameGenerate string
	DevicePath   string
}

type VolumeMode ¶ added in v0.3.0

type VolumeMode int

const (
	FileSystem VolumeMode = iota
	Block
)

type VolumeMountDetails ¶

type VolumeMountDetails struct {
	NameGenerate      string
	MountPathGenerate string
	ReadOnly          bool
}