testsuites

package
v1.1.13 Latest Latest
Warning

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

 Go to latest Published: May 14, 2024 License: Apache-2.0 Imports: 27 Imported by: 1

Documentation

Index

Constants

View Source 
const (
	VolumeSnapshotKind      = "VolumeSnapshot"
	SnapshotAPIVersion      = "snapshot.storage.k8s.io/v1"
	APIVersionv1            = "v1"
	VolumeSnapshotClassKind = "VolumeSnapshotClass"
)
View Source 
const (
	BusyboxTestImage = "gcr.io/google_containers/busybox:1.24"
	MountPath        = "/devtestvol"
)

Variables

View Source 
var (
	SnapshotAPIGroup = "snapshot.storage.k8s.io"
)

Functions

func GetVolumeSnapshotClass 

func GetVolumeSnapshotClass(namespace string) *volumesnapshotv1.VolumeSnapshotClass

func WaitForFileSystemToResize 

func WaitForFileSystemToResize(t *TestPod, expectedOut int64, timeout time.Duration, interval time.Duration) error

WaitForFileSystemToResize waiting for pvc size to be resized to desired size

func WaitForPvToResize 

func WaitForPvToResize(c clientset.Interface, ns *v1.Namespace, pvName string, desiredSize resource.Quantity, timeout time.Duration, interval time.Duration) error

WaitForPvToResize waiting for pvc size to be resized to desired size

Types

type DataSource 

type DataSource struct {
	Name string
}

type DynamicallyProvisioneDeployWithVolWRTest 

type DynamicallyProvisioneDeployWithVolWRTest struct {
	Pod      PodDetails
	PodCheck *PodExecCheck
}

DynamicallyProvisioneVolPodWRTest will provision required PVC 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 (*DynamicallyProvisioneDeployWithVolWRTest) Run 

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

func (*DynamicallyProvisioneDeployWithVolWRTest) RunMultiVol 

func (t *DynamicallyProvisioneDeployWithVolWRTest) RunMultiVol(client clientset.Interface, namespace *v1.Namespace)

type DynamicallyProvisioneMultiPodWithVolTest 

type DynamicallyProvisioneMultiPodWithVolTest struct {
	Pods     []PodDetails
	PodCheck *PodExecCheck
}

DynamicallyProvisioneVolPodWRTest will provision required PVC 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 (*DynamicallyProvisioneMultiPodWithVolTest) RunAsync 

func (t *DynamicallyProvisioneMultiPodWithVolTest) RunAsync(client clientset.Interface, namespace *v1.Namespace)

func (*DynamicallyProvisioneMultiPodWithVolTest) RunSync 

func (t *DynamicallyProvisioneMultiPodWithVolTest) RunSync(client clientset.Interface, namespace *v1.Namespace)

type DynamicallyProvisionePodWithVolTest 

type DynamicallyProvisionePodWithVolTest struct {
	Pods     []PodDetails
	PodCheck *PodExecCheck
}

DynamicallyProvisioneVolPodWRTest will provision required PVC 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 (*DynamicallyProvisionePodWithVolTest) Run 

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

type DynamicallyProvisionedResizeVolumeTest 

type DynamicallyProvisionedResizeVolumeTest struct {
	Pods           []PodDetails
	PodCheck       *PodExecCheck
	ExpandVolSizeG int64
	ExpandedSize   int64
}

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

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

type DynamicallyProvisionedVolumeSnapshotTest 

type DynamicallyProvisionedVolumeSnapshotTest struct {
	Pod         PodDetails
	RestoredPod PodDetails
	PodCheck    *PodExecCheck
	PVCFail     bool
}

func (*DynamicallyProvisionedVolumeSnapshotTest) Run 

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

func (*DynamicallyProvisionedVolumeSnapshotTest) SnapShotForUnattached 

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

func (*DynamicallyProvisionedVolumeSnapshotTest) VolumeSizeLess 

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

type PodDetails 

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

func (*PodDetails) SetupDeployment 

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

func (*PodDetails) SetupDeploymentWithMultiVol 

func (pod *PodDetails) SetupDeploymentWithMultiVol(client clientset.Interface, namespace *v1.Namespace) (*TestDeployment, []func())

func (*PodDetails) SetupStatefulset 

func (pod *PodDetails) SetupStatefulset(client clientset.Interface, namespace *v1.Namespace, serviceName string, labels map[string]string, replicaCount int32) (*TestStatefulsets, []func())

func (*PodDetails) SetupWithDynamicVolumes 

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

func (*PodDetails) SetupWithPVC 

func (pod *PodDetails) SetupWithPVC(client clientset.Interface, namespace *v1.Namespace, name string) (*TestPod, []func())

type PodExecCheck 

type PodExecCheck struct {
	Cmd              []string
	ExpectedString01 string
	ExpectedString02 string
}

type StatefulsetWithVolWRTest 

type StatefulsetWithVolWRTest struct {
	Pod          PodDetails
	PodCheck     *PodExecCheck
	Labels       map[string]string
	ReplicaCount int32
	ServiceName  string
}

func (*StatefulsetWithVolWRTest) Run 

func (t *StatefulsetWithVolWRTest) Run(client clientset.Interface, namespace *v1.Namespace, drainNode bool)

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 bool) *TestDeployment

func NewTestDeploymentWitoutPVC 

func NewTestDeploymentWitoutPVC(c clientset.Interface, ns *v1.Namespace, command string) *TestDeployment

func (*TestDeployment) Cleanup 

func (t *TestDeployment) Cleanup()

func (*TestDeployment) Create 

func (t *TestDeployment) Create()

func (*TestDeployment) DeletePodAndWait 

func (t *TestDeployment) DeletePodAndWait()

func (*TestDeployment) Exec 

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

func (*TestDeployment) Logs 

func (t *TestDeployment) Logs()

func (*TestDeployment) SetupVolume 

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

func (*TestDeployment) WaitForPodReady 

func (t *TestDeployment) WaitForPodReady()

type TestHeadlessService 

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

func NewHeadlessService 

func NewHeadlessService(c clientset.Interface, name, namespace, labelSelctors string) *TestHeadlessService

func (*TestHeadlessService) Cleanup 

func (h *TestHeadlessService) Cleanup()

func (*TestHeadlessService) Create 

func (h *TestHeadlessService) Create() v1.Service

type TestPersistentVolumeClaim 

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

func NewTestPersistentVolumeClaim 

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

func NewTestPersistentVolumeClaimWithDataSource 

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

func (*TestPersistentVolumeClaim) Cleanup 

func (t *TestPersistentVolumeClaim) Cleanup()

func (*TestPersistentVolumeClaim) Create 

func (t *TestPersistentVolumeClaim) Create()

func (*TestPersistentVolumeClaim) DeleteBoundPersistentVolume 

func (t *TestPersistentVolumeClaim) DeleteBoundPersistentVolume()

func (*TestPersistentVolumeClaim) NewTestStatefulset 

func (t *TestPersistentVolumeClaim) NewTestStatefulset(c clientset.Interface, ns *v1.Namespace, servicename, command, storageClassName, volumeName, mountPath string, labels map[string]string, replicaCount int32) *TestStatefulsets

func (*TestPersistentVolumeClaim) ReclaimPolicy 

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

func (*TestPersistentVolumeClaim) ValidateProvisionedPersistentVolume 

func (t *TestPersistentVolumeClaim) ValidateProvisionedPersistentVolume()

func (*TestPersistentVolumeClaim) WaitForBound 

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

func (*TestPersistentVolumeClaim) WaitForPending 

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

func (*TestPersistentVolumeClaim) WaitForPersistentVolumePhase 

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

func NewTestPodWithName 

func NewTestPodWithName(c clientset.Interface, ns *v1.Namespace, name, command string) *TestPod

func (*TestPod) Cleanup 

func (t *TestPod) Cleanup()

func (*TestPod) Create 

func (t *TestPod) Create()

func (*TestPod) Delete 

func (t *TestPod) Delete()

func (*TestPod) DumpDbgInfoOff 

func (t *TestPod) DumpDbgInfoOff()

func (*TestPod) DumpLogOff 

func (t *TestPod) DumpLogOff()

func (*TestPod) Exec 

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

func (*TestPod) Logs 

func (t *TestPod) Logs()

func (*TestPod) SetNodeSelector 

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

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

func (t *TestPod) WaitForFailure()

func (*TestPod) WaitForRunning 

func (t *TestPod) WaitForRunning()

func (*TestPod) WaitForRunningSlow 

func (t *TestPod) WaitForRunningSlow()

func (*TestPod) WaitForSuccess 

func (t *TestPod) WaitForSuccess()

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() v1.PersistentVolume

type TestSecret 

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

func NewSecret 

func NewSecret(c clientset.Interface, name, ns, iops, tags, encrypt, encryptKey, stype string) *TestSecret

func (*TestSecret) Cleanup 

func (s *TestSecret) Cleanup()

func (*TestSecret) Create 

func (s *TestSecret) Create()

type TestStatefulsets 

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

func (*TestStatefulsets) Cleanup 

func (t *TestStatefulsets) Cleanup()

func (*TestStatefulsets) Create 

func (t *TestStatefulsets) Create()

func (*TestStatefulsets) Exec 

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

func (*TestStatefulsets) Logs 

func (t *TestStatefulsets) Logs()

func (*TestStatefulsets) WaitForPodReady 

func (t *TestStatefulsets) WaitForPodReady()

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

func (*TestStorageClass) Create 

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

type TestVolumeSnapshotClass 

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

func CreateVolumeSnapshotClass 

func CreateVolumeSnapshotClass(client restclientset.Interface, namespace *v1.Namespace) (*TestVolumeSnapshotClass, func())

func NewTestVolumeSnapshotClass 

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

func (*TestVolumeSnapshotClass) Cleanup 

func (t *TestVolumeSnapshotClass) Cleanup()

func (*TestVolumeSnapshotClass) Create 

func (t *TestVolumeSnapshotClass) Create()

func (*TestVolumeSnapshotClass) CreateSnapshot 

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

func (*TestVolumeSnapshotClass) DeleteSnapshot 

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

func (*TestVolumeSnapshotClass) ReadyToUse 

func (t *TestVolumeSnapshotClass) ReadyToUse(snapshot *volumesnapshotv1.VolumeSnapshot, snapFail bool)

type VolumeDetails 

type VolumeDetails struct {
	PVCName               string //PVC Name
	VolumeType            string //PVC SC
	FSType                string //Ext3 / XFS / EXT4
	Encrypted             bool
	MountOptions          []string
	ClaimSize             string //PVC Capacity
	ReclaimPolicy         *v1.PersistentVolumeReclaimPolicy
	VolumeBindingMode     *storagev1.VolumeBindingMode
	AllowedTopologyValues []string
	AccessMode            *v1.PersistentVolumeAccessMode
	VolumeMode            VolumeMode
	VolumeMount           VolumeMountDetails
	VolumeDevice          VolumeDeviceDetails

	DataSource *DataSource
	// contains filtered or unexported fields
}

func (*VolumeDetails) SetupDynamicPersistentVolumeClaim 

func (volume *VolumeDetails) SetupDynamicPersistentVolumeClaim(client clientset.Interface, namespace *v1.Namespace, pvcErrExpected bool) (*TestPersistentVolumeClaim, []func())

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.