const Kb … const Mb … const Gb … const Tb … const KiB … const MiB … const GiB … const TiB … const VolumeServerPodStartupTimeout … const PodCleanupTimeout … type SizeRange … type TestConfig … type Test … // NewNFSServer is a NFS-specific wrapper for CreateStorageServer. func NewNFSServer(ctx context.Context, cs clientset.Interface, namespace string, args []string) (config TestConfig, pod *v1.Pod, host string) { … } func NewNFSServerWithNodeName(ctx context.Context, cs clientset.Interface, namespace string, args []string, nodeName string) (config TestConfig, pod *v1.Pod, host string) { … } // CreateStorageServer is a wrapper for startVolumeServer(). A storage server config is passed in, and a pod pointer // and ip address string are returned. // Note: Expect() is called so no error is returned. func CreateStorageServer(ctx context.Context, cs clientset.Interface, config TestConfig) (pod *v1.Pod, ip string) { … } // GetVolumeAttachmentName returns the hash value of the provisioner, the config ClientNodeSelection name, // and the VolumeAttachment name of the PV that is bound to the PVC with the passed in claimName and claimNamespace. func GetVolumeAttachmentName(ctx context.Context, cs clientset.Interface, config TestConfig, provisioner string, claimName string, claimNamespace string) string { … } // getVolumeHandle returns the VolumeHandle of the PV that is bound to the PVC with the passed in claimName and claimNamespace. func getVolumeHandle(ctx context.Context, cs clientset.Interface, claimName string, claimNamespace string) string { … } // WaitForVolumeAttachmentTerminated waits for the VolumeAttachment with the passed in attachmentName to be terminated. func WaitForVolumeAttachmentTerminated(ctx context.Context, attachmentName string, cs clientset.Interface, timeout time.Duration) error { … } // startVolumeServer starts a container specified by config.serverImage and exports all // config.serverPorts from it. The returned pod should be used to get the server // IP address and create appropriate VolumeSource. func startVolumeServer(ctx context.Context, client clientset.Interface, config TestConfig) *v1.Pod { … } // TestServerCleanup cleans server pod. func TestServerCleanup(ctx context.Context, f *framework.Framework, config TestConfig) { … } func runVolumeTesterPod(ctx context.Context, client clientset.Interface, timeouts *framework.TimeoutContext, config TestConfig, podSuffix string, privileged bool, fsGroup *int64, tests []Test, slow bool) (*v1.Pod, error) { … } func testVolumeContent(f *framework.Framework, pod *v1.Pod, containerName string, fsGroup *int64, fsType string, tests []Test) { … } // TestVolumeClient start a client pod using given VolumeSource (exported by startVolumeServer()) // and check that the pod sees expected data, e.g. from the server pod. // Multiple Tests can be specified to mount multiple volumes to a single // pod. // Timeout for dynamic provisioning (if "WaitForFirstConsumer" is set && provided PVC is not bound yet), // pod creation, scheduling and complete pod startup (incl. volume attach & mount) is pod.podStartTimeout. // It should be used for cases where "regular" dynamic provisioning of an empty volume is requested. func TestVolumeClient(ctx context.Context, f *framework.Framework, config TestConfig, fsGroup *int64, fsType string, tests []Test) { … } // TestVolumeClientSlow is the same as TestVolumeClient except for its timeout. // Timeout for dynamic provisioning (if "WaitForFirstConsumer" is set && provided PVC is not bound yet), // pod creation, scheduling and complete pod startup (incl. volume attach & mount) is pod.slowPodStartTimeout. // It should be used for cases where "special" dynamic provisioning is requested, such as volume cloning // or snapshot restore. func TestVolumeClientSlow(ctx context.Context, f *framework.Framework, config TestConfig, fsGroup *int64, fsType string, tests []Test) { … } func testVolumeClient(ctx context.Context, f *framework.Framework, config TestConfig, fsGroup *int64, fsType string, tests []Test, slow bool) { … } // InjectContent inserts index.html with given content into given volume. It does so by // starting and auxiliary pod which writes the file there. // The volume must be writable. func InjectContent(ctx context.Context, f *framework.Framework, config TestConfig, fsGroup *int64, fsType string, tests []Test) { … } // generateWriteCmd is used by generateWriteBlockCmd and generateWriteFileCmd func generateWriteCmd(content, path string) []string { … } // GenerateReadBlockCmd generates the corresponding command lines to read from a block device with the given file path. func GenerateReadBlockCmd(fullPath string, numberOfCharacters int) []string { … } // generateWriteBlockCmd generates the corresponding command lines to write to a block device the given content. func generateWriteBlockCmd(content, fullPath string) []string { … } // GenerateReadFileCmd generates the corresponding command lines to read from a file with the given file path. func GenerateReadFileCmd(fullPath string) []string { … } // generateWriteFileCmd generates the corresponding command lines to write a file with the given content and file path. func generateWriteFileCmd(content, fullPath string) []string { … } // CheckVolumeModeOfPath check mode of volume func CheckVolumeModeOfPath(f *framework.Framework, pod *v1.Pod, volMode v1.PersistentVolumeMode, path string) { … } // PodExec runs f.ExecCommandInContainerWithFullOutput to execute a shell cmd in target pod // TODO: put this under e2epod once https://github.com/kubernetes/kubernetes/issues/81245 // is resolved. Otherwise there will be dependency issue. func PodExec(f *framework.Framework, pod *v1.Pod, shExec string) (string, string, error) { … } // VerifyExecInPodSucceed verifies shell cmd in target pod succeed // TODO: put this under e2epod once https://github.com/kubernetes/kubernetes/issues/81245 // is resolved. Otherwise there will be dependency issue. func VerifyExecInPodSucceed(f *framework.Framework, pod *v1.Pod, shExec string) { … } // VerifyExecInPodFail verifies shell cmd in target pod fail with certain exit code // TODO: put this under e2epod once https://github.com/kubernetes/kubernetes/issues/81245 // is resolved. Otherwise there will be dependency issue. func VerifyExecInPodFail(f *framework.Framework, pod *v1.Pod, shExec string, exitCode int) { … }
Codebase Browser
kubernetes