mirror of
https://github.com/k3s-io/kubernetes.git
synced 2025-07-21 19:01:49 +00:00
remove unused function on b/test/integration/util/util.go
This commit is contained in:
parent
9dbe4c8508
commit
ef410d18e1
@ -878,18 +878,6 @@ func GetPod(cs clientset.Interface, podName string, podNamespace string) (*v1.Po
|
|||||||
return cs.CoreV1().Pods(podNamespace).Get(context.TODO(), podName, metav1.GetOptions{})
|
return cs.CoreV1().Pods(podNamespace).Get(context.TODO(), podName, metav1.GetOptions{})
|
||||||
}
|
}
|
||||||
|
|
||||||
// podScheduled returns true if a node is assigned to the given pod.
|
|
||||||
func podScheduled(c clientset.Interface, podNamespace, podName string) wait.ConditionFunc {
|
|
||||||
return func() (bool, error) {
|
|
||||||
pod, err := c.CoreV1().Pods(podNamespace).Get(context.TODO(), podName, metav1.GetOptions{})
|
|
||||||
if err != nil {
|
|
||||||
// This could be a connection error so we want to retry.
|
|
||||||
return false, nil
|
|
||||||
}
|
|
||||||
return pod.Spec.NodeName != "", nil
|
|
||||||
}
|
|
||||||
}
|
|
||||||
|
|
||||||
func CreateNamespacesWithLabels(cs clientset.Interface, namespaces []string, labels map[string]string) error {
|
func CreateNamespacesWithLabels(cs clientset.Interface, namespaces []string, labels map[string]string) error {
|
||||||
for _, n := range namespaces {
|
for _, n := range namespaces {
|
||||||
ns := v1.Namespace{ObjectMeta: metav1.ObjectMeta{Name: n, Labels: labels}}
|
ns := v1.Namespace{ObjectMeta: metav1.ObjectMeta{Name: n, Labels: labels}}
|
||||||
|
Loading…
Reference in New Issue
Block a user