Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 146 for podIps (0.79 sec)

  1. cni/pkg/nodeagent/net_test.go

    	var podStatus corev1.PodStatus
    	if v6IP {
    		podStatus = corev1.PodStatus{
    			PodIP:  "e9ac:1e77:90ca:399f:4d6d:ece2:2f9b:3164",
    			PodIPs: []corev1.PodIP{{IP: "e9ac:1e77:90ca:399f:4d6d:ece2:2f9b:3164"}, {IP: "e9ac:1e77:90ca:399f:4d6d:ece2:2f9b:3165"}},
    		}
    	} else {
    		podStatus = corev1.PodStatus{
    			PodIP:  "2.2.2.2",
    			PodIPs: []corev1.PodIP{{IP: "2.2.2.2"}, {IP: "3.3.3.3"}},
    		}
    	}
    
    	return &corev1.Pod{
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Thu Jun 06 05:10:23 UTC 2024
    - 17.8K bytes
    - Viewed (0)
  2. cni/pkg/nodeagent/net.go

    	var addedIPSnapshot []netip.Addr
    
    	for _, pod := range ambientPods {
    		podIPs := util.GetPodIPsIfPresent(pod)
    		if len(podIPs) == 0 {
    			log.Warnf("pod %s does not appear to have any assigned IPs, not syncing with ipset", pod.Name)
    		} else {
    			addedIps, err := addPodToHostNSIpset(pod, podIPs, &s.hostsideProbeIPSet)
    			if err != nil {
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Thu Jun 06 05:10:23 UTC 2024
    - 13.4K bytes
    - Viewed (0)
  3. pkg/kubelet/kubelet_pods.go

    	podIPs := make([]string, len(podStatus.IPs))
    	copy(podIPs, podStatus.IPs)
    
    	// make podIPs order match node IP family preference #97979
    	podIPs = kl.sortPodIPs(podIPs)
    	for _, ip := range podIPs {
    		apiPodStatus.PodIPs = append(apiPodStatus.PodIPs, v1.PodIP{IP: ip})
    	}
    	if len(apiPodStatus.PodIPs) > 0 {
    		apiPodStatus.PodIP = apiPodStatus.PodIPs[0].IP
    	}
    
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Fri Jun 14 16:09:17 UTC 2024
    - 101.2K bytes
    - Viewed (0)
  4. pkg/kubelet/kubelet_pods_test.go

    			}
    
    			status := kl.generateAPIPodStatus(pod, criStatus, false)
    			if !reflect.DeepEqual(status.PodIPs, tc.podIPs) {
    				t.Fatalf("Expected PodIPs %#v, got %#v", tc.podIPs, status.PodIPs)
    			}
    			if status.PodIP != status.PodIPs[0].IP {
    				t.Fatalf("Expected PodIP %q to equal PodIPs[0].IP %q", status.PodIP, status.PodIPs[0].IP)
    			}
    		})
    	}
    }
    
    func TestSortPodIPs(t *testing.T) {
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Fri Jun 07 00:05:23 UTC 2024
    - 198.8K bytes
    - Viewed (0)
  5. cni/pkg/nodeagent/cni-watcher.go

    	var podIps []netip.Addr
    	for _, configuredPodIPs := range addCmd.IPs {
    		// net.ip is implicitly convertible to netip as slice
    		ip, _ := netip.AddrFromSlice(configuredPodIPs.Address.IP)
    		// We ignore the mask of the IPNet - it's fine if the IPNet defines
    		// a block grant of addresses, we just need one for checking routes.
    		podIps = append(podIps, ip)
    	}
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Thu Jun 06 21:31:35 UTC 2024
    - 6.7K bytes
    - Viewed (0)
  6. cni/pkg/nodeagent/informers.go

    			// the CNI plugin chain, and have a PodIP.
    			//
    			// If PodIPs exists, it is preferred, otherwise fallback to PodIP.
    			//
    			// If we get to this point and have a pod that really and truly has no IP in either of those,
    			// it's not routable at this point and something is wrong/we should discard this event.
    			podIPs := util.GetPodIPsIfPresent(pod)
    			if len(podIPs) == 0 {
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Thu Jun 06 21:31:35 UTC 2024
    - 11.8K bytes
    - Viewed (0)
  7. pkg/controller/endpointslice/endpointslice_controller_test.go

    		},
    		Spec: v1.PodSpec{
    			Containers: []v1.Container{{
    				Name: "container-1",
    			}},
    			NodeName: "node-1",
    		},
    		Status: v1.PodStatus{
    			PodIP: fmt.Sprintf("1.2.3.%d", 4+n),
    			PodIPs: []v1.PodIP{{
    				IP: fmt.Sprintf("1.2.3.%d", 4+n),
    			}},
    			Conditions: []v1.PodCondition{
    				{
    					Type:   v1.PodReady,
    					Status: status,
    				},
    			},
    		},
    	}
    
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Tue Jun 04 08:33:32 UTC 2024
    - 65.5K bytes
    - Viewed (0)
  8. tests/integration/pilot/gateway_test.go

    		RequiresLocalControlPlane().
    		Run(func(t framework.TestContext) {
    			c := t.Clusters().Default()
    			podIPs, err := i.PodIPsFor(c, i.Settings().SystemNamespace, "app=istio-ingressgateway")
    			if err != nil {
    				t.Fatalf("error getting ingress gateway pod ips: %v", err)
    			}
    			for _, ip := range podIPs {
    				t.NewSubTest("gateway-metrics-endpoints-" + ip.IP).Run(func(t framework.TestContext) {
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Thu Jun 06 22:12:34 UTC 2024
    - 17.7K bytes
    - Viewed (0)
  9. cni/pkg/nodeagent/informers_test.go

    	handlers := setupHandlers(ctx, client, server, "istio-system")
    	client.RunAndWait(ctx.Done())
    	pods := handlers.GetActiveAmbientPodSnapshot()
    
    	// Should only return pods with the annotation indicating they are actually redirected at this time,
    	// not pods that are just scheduled to be enrolled.
    	assert.Equal(t, len(pods), 1)
    	assert.Equal(t, pods[0], redirectedNotEnrolled)
    }
    
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Thu Jun 06 05:10:23 UTC 2024
    - 22.2K bytes
    - Viewed (0)
  10. pkg/kubelet/kuberuntime/kuberuntime_container.go

    	opts, cleanupAction, err := m.runtimeHelper.GenerateRunContainerOptions(ctx, pod, container, podIP, podIPs)
    	if err != nil {
    		return nil, nil, err
    	}
    
    	uid, username, err := m.getImageUser(ctx, container.Image)
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Tue Jun 04 06:25:43 UTC 2024
    - 54.7K bytes
    - Viewed (0)
Back to top