- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 233 for podIPs (0.07 sec)
-
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) -
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) -
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) -
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) -
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) -
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) -
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) -
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) -
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) -
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)