Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 233 for podIPs (0.07 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
    Registered: Wed Nov 06 22:53:10 UTC 2024
    - Last Modified: Wed Oct 09 16:05:45 UTC 2024
    - 4.7K bytes
    - Viewed (0)
  2. 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{
    Registered: Wed Nov 06 22:53:10 UTC 2024
    - Last Modified: Thu Jul 25 16:13:38 UTC 2024
    - 10.7K bytes
    - Viewed (0)
  3. cni/pkg/nodeagent/server_test.go

    		"foo-v6",
    		netip.MustParseAddr("e9ac:1e77:90ca:399f:4d6d:ece2:2f9b:3165"),
    		ipProto,
    		podUID,
    		false,
    	).Return(nil)
    
    	podIPs := []netip.Addr{netip.MustParseAddr(pod.Status.PodIPs[0].IP), netip.MustParseAddr(pod.Status.PodIPs[1].IP)}
    	_, err := m.addPodToHostNSIpset(pod, podIPs)
    	assert.NoError(t, err)
    
    	fakeIPSetDeps.AssertExpectations(t)
    }
    
    func TestMeshDataplaneAddPodToHostNSIPSetsDualstack(t *testing.T) {
    Registered: Wed Nov 06 22:53:10 UTC 2024
    - Last Modified: Wed Oct 09 16:05:45 UTC 2024
    - 18.7K bytes
    - Viewed (0)
  4. cni/pkg/nodeagent/server.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 {
    			addedIps, err := s.addPodToHostNSIpset(pod, podIPs)
    			if err != nil {
    				log.Errorf("pod %s has IP collision, pod will be skipped and will fail healthchecks", pod.Name, podIPs)
    			}
    Registered: Wed Nov 06 22:53:10 UTC 2024
    - Last Modified: Wed Sep 25 20:54:34 UTC 2024
    - 13.4K bytes
    - Viewed (0)
  5. 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)
    }
    
    Registered: Wed Nov 06 22:53:10 UTC 2024
    - Last Modified: Wed Oct 09 16:05:45 UTC 2024
    - 4.9K bytes
    - Viewed (0)
  6. 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.Unmap())
    	}
    Registered: Wed Nov 06 22:53:10 UTC 2024
    - Last Modified: Tue Jul 02 18:48:50 UTC 2024
    - 6.7K bytes
    - Viewed (0)
  7. cni/pkg/nodeagent/informers.go

    		}
    
    		// Exclude ztunnels, and terminated daemonset pods
    		// from the snapshot.
    		if !util.IsZtunnelPod(s.systemNamespace, pod) &&
    			!kube.CheckPodTerminal(pod) &&
    			util.PodRedirectionActive(pod) {
    			pods = append(pods, pod)
    		}
    	}
    	return pods
    }
    
    // EnqueueNamespace takes a Namespace and enqueues all Pod objects that make need an update
    Registered: Wed Nov 06 22:53:10 UTC 2024
    - Last Modified: Wed Oct 09 16:05:45 UTC 2024
    - 11.7K bytes
    - Viewed (0)
  8. cni/pkg/nodeagent/net.go

    	podIptables        *iptables.IptablesConfigurator
    	podNs              PodNetnsFinder
    	// allow overriding for tests
    	netnsRunner func(fdable NetnsFd, toRun func() error) error
    }
    
    var _ MeshDataplane = &NetServer{}
    
    func newNetServer(ztunnelServer ZtunnelServer, podNsMap *podNetnsCache, podIptables *iptables.IptablesConfigurator, podNs PodNetnsFinder) *NetServer {
    	return &NetServer{
    Registered: Wed Nov 06 22:53:10 UTC 2024
    - Last Modified: Mon Oct 21 16:48:55 UTC 2024
    - 9.1K 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: Wed Nov 06 22:53:10 UTC 2024
    - Last Modified: Wed Oct 09 16:05:45 UTC 2024
    - 22.1K bytes
    - Viewed (0)
  10. common-protos/k8s.io/api/core/v1/generated.proto

      optional string podIP = 6;
    
      // podIPs holds the IP addresses allocated to the pod. If this field is specified, the 0th entry must
      // match the podIP field. Pods may be allocated at most 1 value for each of IPv4 and IPv6. This list
      // is empty if no IPs have been allocated yet.
      // +optional
      // +patchStrategy=merge
      // +patchMergeKey=ip
      repeated PodIP podIPs = 12;
    
    Registered: Wed Nov 06 22:53:10 UTC 2024
    - Last Modified: Mon Mar 11 18:43:24 UTC 2024
    - 255.8K bytes
    - Viewed (0)
Back to top