type KubeletOpt … const NodeStateTimeout … const KStart … const KStop … const KRestart … const minValidSize … const maxValidSize … // VerifyFSGroupInPod verifies that the passed in filePath contains the expectedFSGroup func VerifyFSGroupInPod(f *framework.Framework, filePath, expectedFSGroup string, pod *v1.Pod) { … } // getKubeletRunning return if the kubelet is running or not func getKubeletRunning(ctx context.Context, nodeIP string) bool { … } // TestKubeletRestartsAndRestoresMount tests that a volume mounted to a pod remains mounted after a kubelet restarts func TestKubeletRestartsAndRestoresMount(ctx context.Context, c clientset.Interface, f *framework.Framework, clientPod *v1.Pod, volumePath string) { … } // TestKubeletRestartsAndRestoresMap tests that a volume mapped to a pod remains mapped after a kubelet restarts func TestKubeletRestartsAndRestoresMap(ctx context.Context, c clientset.Interface, f *framework.Framework, clientPod *v1.Pod, volumePath string) { … } // TestVolumeUnmountsFromDeletedPodWithForceOption tests that a volume unmounts if the client pod was deleted while the kubelet was down. // forceDelete is true indicating whether the pod is forcefully deleted. // checkSubpath is true indicating whether the subpath should be checked. // If secondPod is set, it is started when kubelet is down to check that the volume is usable while the old pod is being deleted and the new pod is starting. func TestVolumeUnmountsFromDeletedPodWithForceOption(ctx context.Context, c clientset.Interface, f *framework.Framework, clientPod *v1.Pod, forceDelete bool, checkSubpath bool, secondPod *v1.Pod, volumePath string) { … } // TestVolumeUnmountsFromDeletedPod tests that a volume unmounts if the client pod was deleted while the kubelet was down. func TestVolumeUnmountsFromDeletedPod(ctx context.Context, c clientset.Interface, f *framework.Framework, clientPod *v1.Pod, volumePath string) { … } // TestVolumeUnmountsFromForceDeletedPod tests that a volume unmounts if the client pod was forcefully deleted while the kubelet was down. func TestVolumeUnmountsFromForceDeletedPod(ctx context.Context, c clientset.Interface, f *framework.Framework, clientPod *v1.Pod, volumePath string) { … } // TestVolumeUnmapsFromDeletedPodWithForceOption tests that a volume unmaps if the client pod was deleted while the kubelet was down. // forceDelete is true indicating whether the pod is forcefully deleted. func TestVolumeUnmapsFromDeletedPodWithForceOption(ctx context.Context, c clientset.Interface, f *framework.Framework, clientPod *v1.Pod, forceDelete bool, devicePath string) { … } // TestVolumeUnmapsFromDeletedPod tests that a volume unmaps if the client pod was deleted while the kubelet was down. func TestVolumeUnmapsFromDeletedPod(ctx context.Context, c clientset.Interface, f *framework.Framework, clientPod *v1.Pod, devicePath string) { … } // TestVolumeUnmapsFromForceDeletedPod tests that a volume unmaps if the client pod was forcefully deleted while the kubelet was down. func TestVolumeUnmapsFromForceDeletedPod(ctx context.Context, c clientset.Interface, f *framework.Framework, clientPod *v1.Pod, devicePath string) { … } // RunInPodWithVolume runs a command in a pod with given claim mounted to /mnt directory. func RunInPodWithVolume(ctx context.Context, c clientset.Interface, t *framework.TimeoutContext, ns, claimName, command string) { … } // StartExternalProvisioner create external provisioner pod func StartExternalProvisioner(ctx context.Context, c clientset.Interface, ns string, externalPluginName string) *v1.Pod { … } func isSudoPresent(ctx context.Context, nodeIP string, provider string) bool { … } // CheckReadWriteToPath check that path can b e read and written func CheckReadWriteToPath(f *framework.Framework, pod *v1.Pod, volMode v1.PersistentVolumeMode, path string) { … } func readFile(content, path string) string { … } // genBinDataFromSeed generate binData with random seed func genBinDataFromSeed(len int, seed int64) []byte { … } // CheckReadFromPath validate that file can be properly read. // // Note: directIO does not work with (default) BusyBox Pods. A requirement for // directIO to function correctly, is to read whole sector(s) for Block-mode // PVCs (normally a sector is 512 bytes), or memory pages for files (commonly // 4096 bytes). func CheckReadFromPath(f *framework.Framework, pod *v1.Pod, volMode v1.PersistentVolumeMode, directIO bool, path string, len int, seed int64) { … } // CheckWriteToPath that file can be properly written. // // Note: nocache does not work with (default) BusyBox Pods. To read without // caching, enable directIO with CheckReadFromPath and check the hints about // the len requirements. func CheckWriteToPath(f *framework.Framework, pod *v1.Pod, volMode v1.PersistentVolumeMode, nocache bool, path string, len int, seed int64) { … } // GetSectorSize returns the sector size of the device. func GetSectorSize(f *framework.Framework, pod *v1.Pod, device string) int { … } // findMountPoints returns all mount points on given node under specified directory. func findMountPoints(ctx context.Context, hostExec HostExec, node *v1.Node, dir string) []string { … } // FindVolumeGlobalMountPoints returns all volume global mount points on the node of given pod. func FindVolumeGlobalMountPoints(ctx context.Context, hostExec HostExec, node *v1.Node) sets.String { … } // CreateDriverNamespace creates a namespace for CSI driver installation. // The namespace is still tracked and ensured that gets deleted when test terminates. func CreateDriverNamespace(ctx context.Context, f *framework.Framework) *v1.Namespace { … } // WaitForGVRDeletion waits until a non-namespaced object has been deleted func WaitForGVRDeletion(ctx context.Context, c dynamic.Interface, gvr schema.GroupVersionResource, objectName string, poll, timeout time.Duration) error { … } // EnsureGVRDeletion checks that no object as defined by the group/version/kind and name is ever found during the given time period func EnsureGVRDeletion(ctx context.Context, c dynamic.Interface, gvr schema.GroupVersionResource, objectName string, poll, timeout time.Duration, namespace string) error { … } // EnsureNoGVRDeletion checks that an object as defined by the group/version/kind and name has not been deleted during the given time period func EnsureNoGVRDeletion(ctx context.Context, c dynamic.Interface, gvr schema.GroupVersionResource, objectName string, poll, timeout time.Duration, namespace string) error { … } // WaitForNamespacedGVRDeletion waits until a namespaced object has been deleted func WaitForNamespacedGVRDeletion(ctx context.Context, c dynamic.Interface, gvr schema.GroupVersionResource, ns, objectName string, poll, timeout time.Duration) error { … } // WaitUntil runs checkDone until a timeout is reached func WaitUntil(poll, timeout time.Duration, checkDone func() bool) bool { … } // WaitForGVRFinalizer waits until a object from a given GVR contains a finalizer // If namespace is empty, assume it is a non-namespaced object func WaitForGVRFinalizer(ctx context.Context, c dynamic.Interface, gvr schema.GroupVersionResource, objectName, objectNamespace, finalizer string, poll, timeout time.Duration) error { … } // VerifyFilePathGidInPod verfies expected GID of the target filepath func VerifyFilePathGidInPod(f *framework.Framework, filePath, expectedGid string, pod *v1.Pod) { … } // ChangeFilePathGidInPod changes the GID of the target filepath. func ChangeFilePathGidInPod(f *framework.Framework, filePath, targetGid string, pod *v1.Pod) { … } // DeleteStorageClass deletes the passed in StorageClass and catches errors other than "Not Found" func DeleteStorageClass(ctx context.Context, cs clientset.Interface, className string) error { … } // CreateVolumeSource creates a volume source object func CreateVolumeSource(pvcName string, readOnly bool) *v1.VolumeSource { … } // TryFunc try to execute the function and return err if there is any func TryFunc(f func()) error { … } // GetSizeRangesIntersection takes two instances of storage size ranges and determines the // intersection of the intervals (if it exists) and return the minimum of the intersection // to be used as the claim size for the test. // if value not set, that means there's no minimum or maximum size limitation and we set default size for it. func GetSizeRangesIntersection(first e2evolume.SizeRange, second e2evolume.SizeRange) (string, error) { … }
Codebase Browser
kubernetes