Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 4 of 4 for NewPodFetch (0.15 sec)

  1. 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},
    					Scheme:  scheme.HTTP,
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Thu Jun 06 22:12:34 UTC 2024
    - 19.5K bytes
    - Viewed (0)
  2. pkg/test/framework/components/ambient/waypoint.go

    		"waypoint",
    		"delete",
    		"--namespace",
    		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) {
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Thu Jun 06 22:12:34 UTC 2024
    - 6.5K bytes
    - Viewed (0)
  3. tests/integration/ambient/waypoint_test.go

    			}, retry.Timeout(15*time.Second), retry.BackoffDelay(time.Millisecond*100))
    		})
    }
    
    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).
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Thu Jun 06 22:12:34 UTC 2024
    - 11.4K bytes
    - Viewed (0)
  4. tests/integration/ambient/baseline_test.go

    		})
    	})
    }
    
    func TestWaypointChanges(t *testing.T) {
    	framework.NewTest(t).Run(func(t framework.TestContext) {
    		getGracePeriod := func(want int64) bool {
    			pods, err := kubetest.NewPodFetch(t.AllClusters()[0], apps.Namespace.Name(), constants.GatewayNameLabel+"=waypoint")()
    			assert.NoError(t, err)
    			for _, p := range pods {
    				grace := p.Spec.TerminationGracePeriodSeconds
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Wed Jun 12 00:07:28 UTC 2024
    - 78.4K bytes
    - Viewed (0)
Back to top