- Sort Score
- Result 10 results
- Languages All
Results 31 - 40 of 1,182 for podIps (0.12 sec)
-
pkg/util/node/node.go
// (for nodes that actually have dual-stack IPs). Among other things, the IPs returned // from this function are used as the `.status.PodIPs` values for host-network pods on the // node, and the first IP is used as the `.status.HostIP` for all pods on the node. func GetNodeHostIPs(node *v1.Node) ([]net.IP, error) { // Re-sort the addresses with InternalIPs first and then ExternalIPs
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri Jan 27 23:24:38 UTC 2023 - 4.8K bytes - Viewed (0) -
pkg/registry/core/pod/strategy_test.go
}, { in: &api.Pod{ Status: api.PodStatus{ PodIPs: []api.PodIP{ {IP: "1.2.3.4"}, }, }, }, fieldSelector: fields.ParseSelectorOrDie("status.podIP=1.2.3.4"), expectMatch: true, }, { in: &api.Pod{ Status: api.PodStatus{ PodIPs: []api.PodIP{ {IP: "1.2.3.4"}, }, }, },
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Apr 24 18:25:29 UTC 2024 - 76.2K bytes - Viewed (0) -
pkg/kubelet/prober/scale_test.go
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Aug 16 16:33:01 UTC 2023 - 8.2K bytes - Viewed (0) -
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) -
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) -
pkg/controller/endpoint/endpoints_controller_test.go
var ip string if family == v1.IPv4Protocol { ip = fmt.Sprintf("1.2.3.%d", 4+id) } else { ip = fmt.Sprintf("2000::%d", 4+id) } p.Status.PodIPs = append(p.Status.PodIPs, v1.PodIP{IP: ip}) } p.Status.PodIP = p.Status.PodIPs[0].IP return p } func addPods(store cache.Store, namespace string, nPods int, nPorts int, nNotReady int, ipFamilies []v1.IPFamily) {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Mon Feb 26 06:51:56 UTC 2024 - 87.7K bytes - Viewed (0) -
pkg/test/framework/components/echo/kube/workload.go
return n } func (w *workload) Address() string { w.mutex.Lock() ip := w.pod.Status.PodIP w.mutex.Unlock() return ip } func (w *workload) Addresses() []string { w.mutex.Lock() var addresses []string for _, podIP := range w.pod.Status.PodIPs { addresses = append(addresses, podIP.IP) } w.mutex.Unlock() return addresses }
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Wed Oct 25 19:46:28 UTC 2023 - 7.4K bytes - Viewed (0) -
pilot/pkg/serviceregistry/kube/controller/pod.go
// just in case the proxy ID is bad formatted pods := pc.getPodsByIP(proxyIP) switch len(pods) { case 0: return nil case 1: return pods[0] default: // This should only happen with hostNetwork pods, which cannot be proxy clients... log.Errorf("unexpected: found multiple pods for proxy %v (%v)", proxy.ID, proxyIP) // Try to handle it gracefully for _, p := range pods { // At least filter out wrong namespaces...
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Thu May 23 21:07:03 UTC 2024 - 10.8K bytes - Viewed (0) -
pkg/registry/core/service/storage/storage.go
return fmt.Errorf("pod is missing, skipping (%s/%s)", addr.TargetRef.Namespace, addr.TargetRef.Name) } for _, podIP := range pod.Status.PodIPs { if podIP.IP == addr.IP { return nil } } return fmt.Errorf("pod ip(s) doesn't match endpoint ip, skipping: %v vs %s (%s/%s)", pod.Status.PodIPs, addr.IP, addr.TargetRef.Namespace, addr.TargetRef.Name) }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu Apr 11 13:09:33 UTC 2024 - 22.3K bytes - Viewed (0) -
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)