// WaitAllHTTPBINPods waits until all httpbin pods ready.
WaitAllHTTPBINPods waits until all httpbin pods ready.
// WaitAllHTTPBINPods waits until all httpbin pods ready .
func (s *Scaffold) WaitAllHTTPBINPoddsAvailable() error {
	opts := metav1.ListOptions{
		LabelSelector: "app=httpbin-deployment-e2e-test",
	}
	condFunc := func() (bool, error) {
		items, err := k8s.ListPodsE(s.t, s.kubectlOptions, opts)
		if err != nil {
			return false, err
		}
		if len(items) == 0 {
			ginkgo.GinkgoT().Log("no apisix pods created")
			return false, nil
		}
		for _, item := range items {
			foundPodReady := false
			for _, cond := range item.Status.Conditions {
				if cond.Type != corev1.PodReady {
					continue
				}
				foundPodReady = true
				if cond.Status != "True" {
					return false, nil
				}
			}
			if !foundPodReady {
				return false, nil
			}
		}
		return true, nil
	}
	return waitExponentialBackoff(condFunc)
}
func ( s * Scaffold ) WaitAllHTTPBINPoddsAvailable ( ) error { opts := metav1 . ListOptions { LabelSelector : " " , } condFunc := func ( ) ( bool , error ) { items , err := k8s . ListPodsE ( s . t , s . kubectlOptions , opts ) if err != nil { return false , err } if len ( items ) == 0 { ginkgo . GinkgoT ( ) . Log ( " " ) return false , nil } for _ , item := range items { foundPodReady := false for _ , cond := range item . Status . Conditions { if cond . Type != corev1 . PodReady { continue } foundPodReady = true if cond . Status != " " { return false , nil } } if ! foundPodReady { return false , nil } } return true , nil } return waitExponentialBackoff ( condFunc ) }
WaitAllHTTPBINPods waits until all httpbin pods ready.
WaitAllHTTPBINPods waits until all httpbin pods ready .