Versions in this module Expand all Collapse all v1 v1.16.3 Oct 23, 2019 Changes in this version + const PodDeleteTimeout + var BusyBoxImage = imageutils.GetE2EImage(imageutils.BusyBox) + func CheckPodsRunningReady(c clientset.Interface, ns string, podNames []string, timeout time.Duration) bool + func CheckPodsRunningReadyOrSucceeded(c clientset.Interface, ns string, podNames []string, timeout time.Duration) bool + func CountRemainingPods(c clientset.Interface, namespace string) (int, int, error) + func CreateClientPod(c clientset.Interface, ns string, pvc *v1.PersistentVolumeClaim) (*v1.Pod, error) + func CreateExecPodOrFail(client clientset.Interface, ns, generateName string, tweak func(*v1.Pod)) *v1.Pod + func CreatePod(client clientset.Interface, namespace string, nodeSelector map[string]string, ...) (*v1.Pod, error) + func CreatePodOrFail(c clientset.Interface, ns, name string, labels map[string]string, ...) + func CreateSecPod(client clientset.Interface, namespace string, ...) (*v1.Pod, error) + func CreateSecPodWithNodeSelection(client clientset.Interface, namespace string, ...) (*v1.Pod, error) + func CreateUnschedulablePod(client clientset.Interface, namespace string, nodeSelector map[string]string, ...) (*v1.Pod, error) + func CreateWaitAndDeletePod(c clientset.Interface, ns string, pvc *v1.PersistentVolumeClaim, ...) (err error) + func DeletePodOrFail(c clientset.Interface, ns, name string) + func DeletePodWithWait(c clientset.Interface, pod *v1.Pod) error + func DeletePodWithWaitByName(c clientset.Interface, podName, podNamespace string) error + func DumpAllPodInfo(c clientset.Interface) + func DumpAllPodInfoForNamespace(c clientset.Interface, namespace string) + func FilterNonRestartablePods(pods []*v1.Pod) []*v1.Pod + func GetPodLogs(c clientset.Interface, namespace, podName, containerName string) (string, error) + func GetPodsInNamespace(c clientset.Interface, ns string, ignoreLabels map[string]string) ([]*v1.Pod, error) + func GetPodsScheduled(masterNodes sets.String, pods *v1.PodList) (scheduledPods, notScheduledPods []v1.Pod) + func GetPreviousPodLogs(c clientset.Interface, namespace, podName, containerName string) (string, error) + func LogPodStates(pods []v1.Pod) + func MakePod(ns string, nodeSelector map[string]string, ...) *v1.Pod + func MakeSecPod(ns string, pvclaims []*v1.PersistentVolumeClaim, ...) *v1.Pod + func NewExecPodSpec(ns, name string, hostNetwork bool) *v1.Pod + func PatchContainerImages(containers []v1.Container) error + func PodsCreated(c clientset.Interface, ns, name string, replicas int32) (*v1.PodList, error) + func PodsCreatedByLabel(c clientset.Interface, ns, name string, replicas int32, label labels.Selector) (*v1.PodList, error) + func PodsResponding(c clientset.Interface, ns, name string, wantName bool, pods *v1.PodList) error + func SetAffinity(nodeSelection *NodeSelection, nodeName string) + func SetAntiAffinity(nodeSelection *NodeSelection, nodeName string) + func VerifyPods(c clientset.Interface, ns, name string, wantName bool, replicas int32) error + func VerifyPodsRunning(c clientset.Interface, ns, name string, wantName bool, replicas int32) error + func WaitForControlledPods(c clientset.Interface, ns, name string, kind schema.GroupKind) (pods *v1.PodList, err error) + func WaitForControlledPodsRunning(c clientset.Interface, ns, name string, kind schema.GroupKind) error + func WaitForMatchPodsCondition(c clientset.Interface, opts metav1.ListOptions, desc string, ...) error + func WaitForNRestartablePods(ps *testutils.PodStore, expect int, timeout time.Duration) ([]string, error) + func WaitForPodCondition(c clientset.Interface, ns, podName, desc string, timeout time.Duration, ...) error + func WaitForPodNameRunningInNamespace(c clientset.Interface, podName, namespace string) error + func WaitForPodNameUnschedulableInNamespace(c clientset.Interface, podName, namespace string) error + func WaitForPodNoLongerRunningInNamespace(c clientset.Interface, podName, namespace string) error + func WaitForPodNotFoundInNamespace(c clientset.Interface, podName, ns string, timeout time.Duration) error + func WaitForPodNotPending(c clientset.Interface, ns, podName string) error + func WaitForPodRunningInNamespace(c clientset.Interface, pod *v1.Pod) error + func WaitForPodRunningInNamespaceSlow(c clientset.Interface, podName, namespace string) error + func WaitForPodSuccessInNamespace(c clientset.Interface, podName string, namespace string) error + func WaitForPodSuccessInNamespaceSlow(c clientset.Interface, podName string, namespace string) error + func WaitForPodTerminatedInNamespace(c clientset.Interface, podName, reason, namespace string) error + func WaitForPodToDisappear(c clientset.Interface, ns, podName string, label labels.Selector, ...) error + func WaitForPodsGone(ps *testutils.PodStore, interval, timeout time.Duration) error + func WaitForPodsInactive(ps *testutils.PodStore, interval, timeout time.Duration) error + func WaitForPodsReady(c clientset.Interface, ns, name string, minReadySeconds int) error + func WaitForPodsRunningReady(c clientset.Interface, ns string, minPods, allowedNotReadyPods int32, ...) error + func WaitForPodsWithLabel(c clientset.Interface, ns string, label labels.Selector) (pods *v1.PodList, err error) + func WaitForPodsWithLabelRunningReady(c clientset.Interface, ns string, label labels.Selector, num int, ...) (pods *v1.PodList, err error) + func WaitForPodsWithLabelScheduled(c clientset.Interface, ns string, label labels.Selector) (pods *v1.PodList, err error) + func WaitTimeoutForPodNoLongerRunningInNamespace(c clientset.Interface, podName, namespace string, timeout time.Duration) error + func WaitTimeoutForPodReadyInNamespace(c clientset.Interface, podName, namespace string, timeout time.Duration) error + func WaitTimeoutForPodRunningInNamespace(c clientset.Interface, podName, namespace string, timeout time.Duration) error + type NodeSelection struct + Affinity *v1.Affinity + Name string + Selector map[string]string + type ProxyResponseChecker struct + func NewProxyResponseChecker(c clientset.Interface, ns string, label labels.Selector, controllerName string, ...) ProxyResponseChecker + func (r ProxyResponseChecker) CheckAllResponses() (done bool, err error)
Go to main page