Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 3 of 3 for NewSinglePodFetch (0.19 sec)

  1. pkg/test/framework/components/istio/kube.go

    }
    
    func (i *istioImpl) PodIPsFor(c cluster.Cluster, namespace string, label string) ([]corev1.PodIP, error) {
    	// Find the pod with the specified label in the specified namespace
    	fetchFn := testKube.NewSinglePodFetch(c, namespace, label)
    	pods, err := testKube.WaitUntilPodsAreReady(fetchFn)
    	if err != nil {
    		return nil, err
    	}
    
    	pod := pods[0]
    	return pod.Status.PodIPs, nil
    }
    
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Thu Jun 06 22:12:34 UTC 2024
    - 31.1K bytes
    - Viewed (0)
  2. tests/integration/pilot/gateway_test.go

            istio.io/gateway-name: managed-owner
        spec:
          containers:
          - name: fake
            image: %s
    `, image)).ApplyOrFail(t)
    	cls := t.Clusters().Default()
    	fetchFn := testKube.NewSinglePodFetch(cls, apps.Namespace.Name(), "gateway.networking.k8s.io/gateway-name=managed-owner")
    	if _, err := testKube.WaitUntilPodsAreReady(fetchFn); err != nil {
    		t.Fatal(err)
    	}
    
    	t.ConfigIstio().YAML(apps.Namespace.Name(), `
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Thu Jun 06 22:12:34 UTC 2024
    - 17.7K bytes
    - Viewed (0)
  3. tests/integration/operator/switch_cr_test.go

    	if err := checkInstallStatus(cs, revision); err != nil {
    		t.Fatalf("IstioOperator status not healthy: %v", err)
    	}
    
    	if _, err := kube2.CheckPodsAreReady(kube2.NewSinglePodFetch(cs, IstioNamespace, "app=istiod")); err != nil {
    		t.Fatalf("istiod pod is not ready: %v", err)
    	}
    
    	// get manifests by running `manifest generate`
    	generateCmd := []string{
    		"manifest", "generate",
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Wed Apr 10 20:33:28 UTC 2024
    - 17.5K bytes
    - Viewed (0)
Back to top