From 17eba2b2f7065150c0045754bc8d5a8853b4fe7c Mon Sep 17 00:00:00 2001 From: Patrick Ohly Date: Wed, 4 Jan 2023 21:20:57 +0100 Subject: [PATCH] e2e framework/pod: add Get helper This helper will be used by several different tests and makes those tests more readable. --- test/e2e/framework/pod/get.go | 31 +++++++++++++++++++++++++++++++ 1 file changed, 31 insertions(+) create mode 100644 test/e2e/framework/pod/get.go diff --git a/test/e2e/framework/pod/get.go b/test/e2e/framework/pod/get.go new file mode 100644 index 00000000000..d83314d1981 --- /dev/null +++ b/test/e2e/framework/pod/get.go @@ -0,0 +1,31 @@ +/* +Copyright 2023 The Kubernetes Authors. + +Licensed under the Apache License, Version 2.0 (the "License"); +you may not use this file except in compliance with the License. +You may obtain a copy of the License at + + http://www.apache.org/licenses/LICENSE-2.0 + +Unless required by applicable law or agreed to in writing, software +distributed under the License is distributed on an "AS IS" BASIS, +WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. +See the License for the specific language governing permissions and +limitations under the License. +*/ + +package pod + +import ( + v1 "k8s.io/api/core/v1" + metav1 "k8s.io/apimachinery/pkg/apis/meta/v1" + clientset "k8s.io/client-go/kubernetes" + "k8s.io/kubernetes/test/e2e/framework" +) + +// Get creates a function which retrieves the pod anew each time the function +// is called. Fatal errors are detected by framework.HandleRetry and cause +// polling to stop. +func Get(c clientset.Interface, pod framework.NamedObject) framework.GetFunc[*v1.Pod] { + return framework.HandleRetry(framework.GetObject(c.CoreV1().Pods(pod.GetNamespace()).Get, pod.GetName(), metav1.GetOptions{})) +}