testsuites

package
v1.17.0 Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Jan 23, 2025 License: Apache-2.0 Imports: 32 Imported by: 0

Documentation

Index

Constants

View Source 
const (
	VolumePVCKind     = "PersistentVolumeClaim"
	APIVersionv1beta1 = "v1beta1"
)

Variables

This section is empty.

Functions

This section is empty.

Types

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 (*DynamicallyProvisionedCmdVolumeTest) Run 

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 (*DynamicallyProvisionedCollocatedPodTest) Run 

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
	SkipAfterRestartCheck  bool
	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 (*DynamicallyProvisionedDeletePodTest) Run 

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

type DynamicallyProvisionedInlineVolumeTest added in v1.17.0 

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

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

func (*DynamicallyProvisionedInlineVolumeTest) Run added in v1.17.0 

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

type DynamicallyProvisionedPodWithMultiplePVsTest 

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 (*DynamicallyProvisionedPodWithMultiplePVsTest) Run 

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 (*DynamicallyProvisionedReadOnlyVolumeTest) Run 

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

type DynamicallyProvisionedReclaimPolicyTest 

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

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

func (*DynamicallyProvisionedReclaimPolicyTest) Run 

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

type DynamicallyProvisionedResizeVolumeTest added in v1.17.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 (*DynamicallyProvisionedResizeVolumeTest) Run added in v1.17.0 

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 (*DynamicallyProvisionedRestartDriverTest) Run added in v1.0.0 

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

type DynamicallyProvisionedVolumeCloningTest added in v1.11.0 

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 (*DynamicallyProvisionedVolumeCloningTest) Run added in v1.11.0 

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

type DynamicallyProvisionedVolumeSubpathTester added in v1.0.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 (*DynamicallyProvisionedVolumeSubpathTester) Run added in v1.0.0 

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

type PodDetails 

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

func (*PodDetails) SetupDeployment 

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

func (*PodDetails) SetupWithCSIInlineVolumes added in v1.17.0 

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

func (*PodDetails) SetupWithDynamicMultipleVolumes 

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

SetupWithDynamicMultipleVolumes each pod will be mounted with multiple volumes

func (*PodDetails) SetupWithDynamicVolumes 

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 (*PodDetails) SetupWithDynamicVolumesWithSubpath added in v1.0.0 

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 (*PodDetails) SetupWithPreProvisionedVolumes 

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 TestDeployment 

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

func NewTestDeployment 

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

func (*TestDeployment) Cleanup 

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

func (*TestDeployment) Create 

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

func (*TestDeployment) DeletePodAndWait 

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

func (*TestDeployment) Logs 

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

func (*TestDeployment) PollForStringInPodsExec added in v1.10.0 

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

func (*TestDeployment) WaitForPodReady 

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

type TestPersistentVolumeClaim 

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

func NewTestPersistentVolumeClaim 

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

func NewTestPersistentVolumeClaimWithDataSource 

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

func (*TestPersistentVolumeClaim) Cleanup 

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

func (*TestPersistentVolumeClaim) Create 

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

func (*TestPersistentVolumeClaim) DeleteBackingVolume 

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

func (*TestPersistentVolumeClaim) DeleteBoundPersistentVolume 

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

func (*TestPersistentVolumeClaim) ReclaimPolicy 

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

func (*TestPersistentVolumeClaim) ValidateProvisionedPersistentVolume 

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

func (*TestPersistentVolumeClaim) WaitForBound 

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

func (*TestPersistentVolumeClaim) WaitForPersistentVolumePhase 

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

type TestPod 

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

func NewTestPod 

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

func (*TestPod) Cleanup 

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

func (*TestPod) Create 

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

func (*TestPod) Logs 

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

func (*TestPod) SetNodeSelector 

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

func (*TestPod) SetupCSIInlineVolume added in v1.17.0 

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

func (*TestPod) SetupRawBlockVolume 

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

func (*TestPod) SetupVolume 

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

func (*TestPod) SetupVolumeMountWithSubpath added in v1.0.0 

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

func (*TestPod) WaitForFailedMountError 

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

func (*TestPod) WaitForFailure 

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

func (*TestPod) WaitForRunning 

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

func (*TestPod) WaitForSuccess 

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

type TestPreProvisionedPersistentVolume 

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

func NewTestPreProvisionedPersistentVolume 

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

func (*TestPreProvisionedPersistentVolume) Create 

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

type TestSecret 

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

func CopyTestSecret added in v1.17.0 

func CopyTestSecret(ctx context.Context, c clientset.Interface, sourceNamespace string, targetNamespace *v1.Namespace, secretName string) *TestSecret

func NewTestSecret 

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

func (*TestSecret) Cleanup 

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

func (*TestSecret) Create 

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

type TestStorageClass 

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

func NewTestStorageClass 

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

func (*TestStorageClass) Cleanup 

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

func (*TestStorageClass) Create 

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 or PVCs
	DataSource *DataSource
	// Optional, used with specified StorageClass
	StorageClass       *storagev1.StorageClass
	ShareName          string
	NodeStageSecretRef string
}

func (*VolumeDetails) CreateStorageClass added in v1.11.0 

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 (*VolumeDetails) SetupDynamicPersistentVolumeClaim 

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 (*VolumeDetails) SetupPreProvisionedPersistentVolumeClaim 

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
}

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.