Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 62 for podIPs (0.22 sec)

  1. cni/pkg/util/podutil.go

    	var podIPs []netip.Addr
    	if len(pod.Status.PodIPs) != 0 {
    		for _, pip := range pod.Status.PodIPs {
    			ip := netip.MustParseAddr(pip.IP)
    			podIPs = append(podIPs, ip)
    		}
    	} else if len(pod.Status.PodIP) != 0 {
    		ip := netip.MustParseAddr(pod.Status.PodIP)
    		podIPs = append(podIPs, ip)
    	}
    	return podIPs
    Go
    - Registered: Wed May 08 22:53:08 GMT 2024
    - Last Modified: Fri May 03 19:29:42 GMT 2024
    - 3.9K bytes
    - Viewed (0)
  2. cni/pkg/nodeagent/net.go

    	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 {
    			err := addPodToHostNSIpset(pod, podIPs, &s.hostsideProbeIPSet)
    			if err != nil {
    				return err
    			}
    			addedIPSnapshot = append(addedIPSnapshot, podIPs...)
    		}
    
    	}
    Go
    - Registered: Wed May 08 22:53:08 GMT 2024
    - Last Modified: Tue Apr 30 22:24:38 GMT 2024
    - 12.2K bytes
    - Viewed (1)
  3. cni/pkg/util/podutil_test.go

    		},
    	}
    
    	podIPs := GetPodIPsIfPresent(pod)
    	assert.Equal(t, len(podIPs), 2)
    }
    
    func TestGetPodIPsIfNoPodIPPresent(t *testing.T) {
    	pod := &corev1.Pod{
    		ObjectMeta: metav1.ObjectMeta{
    			Name:      "test",
    			Namespace: "test",
    		},
    		Spec: corev1.PodSpec{
    			NodeName: "derp",
    		},
    		Status: corev1.PodStatus{},
    	}
    
    	podIPs := GetPodIPsIfPresent(pod)
    	assert.Equal(t, len(podIPs), 0)
    }
    
    Go
    - Registered: Wed May 08 22:53:08 GMT 2024
    - Last Modified: Fri May 03 19:29:42 GMT 2024
    - 4.9K bytes
    - Viewed (0)
  4. cni/pkg/nodeagent/net_test.go

    	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{
    Go
    - Registered: Wed May 08 22:53:08 GMT 2024
    - Last Modified: Tue Apr 30 22:24:38 GMT 2024
    - 16.4K bytes
    - Viewed (0)
  5. cni/pkg/nodeagent/informers.go

    	var pods []*corev1.Pod
    	for _, pod := range s.pods.List(metav1.NamespaceAll, klabels.Everything()) {
    		ns := s.namespaces.Get(pod.Namespace, "")
    		if ns == nil {
    			log.Warnf("failed to find namespace %s for pod %s", pod.Namespace, pod.Name)
    		}
    
    		if !util.IsZtunnelPod(s.systemNamespace, pod) && util.PodRedirectionEnabled(ns, pod) {
    			pods = append(pods, pod)
    		}
    	}
    	return pods
    }
    
    Go
    - Registered: Wed May 08 22:53:08 GMT 2024
    - Last Modified: Fri May 03 19:29:42 GMT 2024
    - 9.6K bytes
    - Viewed (0)
  6. cni/pkg/nodeagent/server.go

    	return s.netServer.ConstructInitialSnapshot(ambientPods)
    }
    
    func (s *meshDataplane) AddPodToMesh(ctx context.Context, pod *corev1.Pod, podIPs []netip.Addr, netNs string) error {
    	var retErr error
    	err := s.netServer.AddPodToMesh(ctx, pod, podIPs, netNs)
    	if err != nil {
    		log.Errorf("failed to add pod to ztunnel: %v", err)
    		if !errors.Is(err, ErrPartialAdd) {
    			return err
    		}
    		retErr = err
    	}
    Go
    - Registered: Wed May 08 22:53:08 GMT 2024
    - Last Modified: Tue Apr 30 22:24:38 GMT 2024
    - 7.2K bytes
    - Viewed (0)
  7. cni/pkg/nodeagent/informers_test.go

    	pod := &corev1.Pod{
    		ObjectMeta: metav1.ObjectMeta{
    			Name:      "test",
    			Namespace: "test",
    		},
    		Spec: corev1.PodSpec{
    			NodeName: NodeName,
    		},
    		Status: corev1.PodStatus{
    			PodIPs: []corev1.PodIP{
    				{
    					IP: "11.1.1.12",
    				},
    			},
    		},
    	}
    	ns := &corev1.Namespace{ObjectMeta: metav1.ObjectMeta{Name: "test"}}
    
    	client := kube.NewFakeClient(ns, pod)
    
    Go
    - Registered: Wed May 08 22:53:08 GMT 2024
    - Last Modified: Fri May 03 19:29:42 GMT 2024
    - 15.8K bytes
    - Viewed (0)
  8. CHANGELOG/CHANGELOG-1.28.md

    - Static pods were taking extra time to be restarted after being updated.  Static pods that are waiting to restart were not correctly counted in `kubelet_working_pods`. ([#116995](https://github.com/kubernetes/kubernetes/pull/116995), [@smarterclayton](https://github.com/smarterclayton)) [SIG Node]
    Plain Text
    - Registered: Fri May 03 09:05:14 GMT 2024
    - Last Modified: Tue Apr 16 20:44:48 GMT 2024
    - 385.1K bytes
    - Viewed (0)
  9. istioctl/pkg/checkinject/checkinject.go

    			if err != nil {
    				return err
    			}
    			var podName, podNs string
    			var podLabels, nsLabels map[string]string
    			if len(args) == 1 {
    				podName, podNs, err = ctx.InferPodInfoFromTypedResource(args[0], ctx.Namespace())
    				if err != nil {
    					return err
    				}
    				pod, err := kubeClient.Kube().CoreV1().Pods(podNs).Get(context.TODO(), podName, metav1.GetOptions{})
    				if err != nil {
    					return err
    Go
    - Registered: Wed May 08 22:53:08 GMT 2024
    - Last Modified: Sat Apr 13 05:23:38 GMT 2024
    - 9.3K bytes
    - Viewed (0)
  10. manifests/charts/istio-cni/templates/clusterrole.yaml

        verbs: ["create", "patch"]
      - apiGroups: [""]
        resources: ["pods"]
        verbs: ["watch", "get", "list"]
    {{- if .Values.cni.repair.repairPods }}
    {{- /*  No privileges needed*/}}
    {{- else if .Values.cni.repair.deletePods }}
      - apiGroups: [""]
        resources: ["pods"]
        verbs: ["delete"]
    {{- else if .Values.cni.repair.labelPods }}
      - apiGroups: [""]
    Others
    - Registered: Wed May 08 22:53:08 GMT 2024
    - Last Modified: Sat May 04 01:55:56 GMT 2024
    - 2.2K bytes
    - Viewed (0)
Back to top