- Sort Score
- Result 10 results
- Languages All
Results 1 - 4 of 4 for CheckPodsAreReady (0.15 sec)
-
pkg/test/kube/util.go
} if len(pods.Items) == 0 { return nil, fmt.Errorf("no pods found for %v", selectors) } return pods.Items, nil } } // CheckPodsAreReady checks whether the pods that are selected by the given function is in ready state or not. func CheckPodsAreReady(fetchFunc PodFetchFunc) ([]corev1.Pod, error) { scopes.Framework.Infof("Checking pods ready...") fetched, err := fetchFunc() if err != nil {
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Mon Dec 04 22:47:52 UTC 2023 - 9.4K bytes - Viewed (0) -
tests/integration/pilot/gw_topology_test.go
imagePullPolicy: {{ .imagePullPolicy }} --- `).ApplyOrFail(t, apply.NoCleanup) cs := t.Clusters().Default().(*kubecluster.Cluster) retry.UntilSuccessOrFail(t, func() error { _, err := kubetest.CheckPodsAreReady(kubetest.NewPodFetch(cs, gatewayNs.Name(), "istio=ingressgateway")) return err }, retry.Timeout(time.Minute*2), retry.Delay(time.Second))
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Mon Apr 08 22:02:59 UTC 2024 - 8K bytes - Viewed (0) -
tests/integration/pilot/revisioned_upgrade_test.go
} fetch := kubetest.NewPodMustFetch(t.Clusters().Default(), revisionedInstance.Config().Namespace.Name(), fmt.Sprintf("app=%s", revisionedInstance.Config().Service)) // nolint: lll pods, err := kubetest.CheckPodsAreReady(fetch) if err != nil { t.Fatalf("failed to retrieve upgraded pods: %v", err) } for _, p := range pods { for _, c := range p.Spec.Containers { if strings.Contains(c.Image, fromVersion) {
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Mon Apr 08 22:02:59 UTC 2024 - 4.9K bytes - Viewed (0) -
pkg/test/framework/components/ambient/waypoint.go
ns.Name(), waypoint, }) waypointError := retry.UntilSuccess(func() error { fetch := testKube.NewPodFetch(t.AllClusters()[0], ns.Name(), constants.GatewayNameLabel+"="+waypoint) pods, err := testKube.CheckPodsAreReady(fetch) if err != nil && !errors.Is(err, testKube.ErrNoPodsFetched) { return fmt.Errorf("cannot fetch pod: %v", err) } else if len(pods) != 0 { return fmt.Errorf("waypoint pod is not deleted") }
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Thu Jun 06 22:12:34 UTC 2024 - 6.5K bytes - Viewed (0)