- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 882 for kubetest (0.16 sec)
-
tests/integration/pilot/gw_topology_test.go
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)) // Apply an envoy filter in a subtest to the existing gateway t.NewSubTest("filter").Run(func(t framework.TestContext) {
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
if err := revisionedInstance.Restart(); err != nil { t.Fatalf("revisioned instance rollout failed with: %v", err) } 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 {
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Mon Apr 08 22:02:59 UTC 2024 - 4.9K bytes - Viewed (0) -
tests/integration/ambient/waypoint_test.go
}) } func checkWaypointIsReady(t framework.TestContext, ns, name string) error { fetch := kubetest.NewPodFetch(t.AllClusters()[0], ns, constants.GatewayNameLabel+"="+name) _, err := kubetest.CheckPodsAreReady(fetch) return err } func TestSimpleHTTPSandwich(t *testing.T) { framework. NewTest(t). Run(func(t framework.TestContext) { config := `
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Thu Jun 06 22:12:34 UTC 2024 - 11.4K bytes - Viewed (0) -
tests/integration/pilot/ingress_test.go
port: number: 80 `).Apply(apply.NoCleanup) cs := t.Clusters().Default().(*kubecluster.Cluster) retry.UntilSuccessOrFail(t, func() error { _, err := kubetest.CheckPodsAreReady(kubetest.NewPodFetch(cs, gatewayNs.Name(), "istio=custom")) return err }, retry.Timeout(time.Minute*2)) apps.B[0].CallOrFail(t, echo.CallOptions{ Port: echo.Port{ServicePort: 80},
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Thu Jun 06 22:12:34 UTC 2024 - 19.5K bytes - Viewed (0) -
tests/integration/helm/util.go
func VerifyPodReady(ctx framework.TestContext, cs cluster.Cluster, ns, label string) { retry.UntilSuccessOrFail(ctx, func() error { if _, err := kubetest.CheckPodsAreReady(kubetest.NewPodFetch(cs, ns, label)); err != nil { return fmt.Errorf("%s pod is not ready: %v", label, err) } return nil }, retry.Timeout(RetryTimeOut), retry.Delay(RetryDelay)) } // VerifyInstallation verify that the Helm installation is successful
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Thu May 09 19:04:51 UTC 2024 - 18.7K bytes - Viewed (0) -
tests/integration/pilot/revisions/revision_tag_test.go
"istio.io/istio/pkg/test/framework/components/echo/deployment" "istio.io/istio/pkg/test/framework/components/istioctl" "istio.io/istio/pkg/test/framework/components/namespace" kubetest "istio.io/istio/pkg/test/kube" ) func TestRevisionTags(t *testing.T) { // nolint: staticcheck framework.NewTest(t). RequiresSingleCluster(). RequiresLocalControlPlane().
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Mon Apr 08 22:02:59 UTC 2024 - 4.2K bytes - Viewed (0) -
tests/integration/helm/upgrade/util.go
} func checkVersion(t framework.TestContext, namespace, version string) error { // func NewPodFetch(a istioKube.CLIClient, namespace string, selectors ...string) PodFetchFunc { fetch := kubetest.NewPodFetch(t.Clusters().Default(), namespace) pods, err := kubetest.CheckPodsAreReady(fetch) if err != nil { return fmt.Errorf("failed to retrieve pods: %v", err) } for _, p := range pods { for _, c := range p.Spec.Containers {
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Thu May 09 19:04:51 UTC 2024 - 14.4K bytes - Viewed (0) -
tests/integration/ambient/cacert_rotation_test.go
"istio.io/istio/pkg/test/framework" "istio.io/istio/pkg/test/framework/components/istio" "istio.io/istio/pkg/test/framework/components/istioctl" "istio.io/istio/pkg/test/framework/components/namespace" kubetest "istio.io/istio/pkg/test/kube" "istio.io/istio/pkg/test/util/assert" "istio.io/istio/pkg/test/util/retry" "istio.io/istio/security/pkg/pki/util" "istio.io/istio/tests/integration/security/util/cert" )
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Tue Apr 16 03:28:36 UTC 2024 - 6.1K bytes - Viewed (0) -
tests/integration/ambient/baseline_test.go
"istio.io/istio/pkg/test/framework/components/prometheus" "istio.io/istio/pkg/test/framework/resource/config/apply" "istio.io/istio/pkg/test/framework/resource/config/cleanup" kubetest "istio.io/istio/pkg/test/kube" "istio.io/istio/pkg/test/util/assert" "istio.io/istio/pkg/test/util/file" "istio.io/istio/pkg/test/util/retry" "istio.io/istio/pkg/util/sets" "istio.io/istio/tests/common/jwt"
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Wed Jun 12 00:07:28 UTC 2024 - 78.4K bytes - Viewed (0) -
src/testing/sub_test.go
}) t.Errorf("Should not reach here.") }, }, { desc: "subtest calls error on ancestor", ok: false, output: ` --- FAIL: subtest calls error on ancestor (N.NNs) sub_test.go:NNN: Report to ancestor --- FAIL: subtest calls error on ancestor/#00 (N.NNs) sub_test.go:NNN: Still do this sub_test.go:NNN: Also do this`, maxPar: 1, f: func(t *T) { outer := t
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Fri Dec 01 21:27:08 UTC 2023 - 23.8K bytes - Viewed (0)