- Sort Score
- Result 10 results
- Languages All
Results 11 - 20 of 273 for podMap (0.17 sec)
-
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) -
pkg/kubelet/lifecycle/handlers_test.go
f.ID = id return []byte(f.Msg), f.Err } func stubPodStatusProvider(podIP string) podStatusProvider { return podStatusProviderFunc(func(uid types.UID, name, namespace string) (*kubecontainer.PodStatus, error) { return &kubecontainer.PodStatus{ ID: uid, Name: name, Namespace: namespace, IPs: []string{podIP}, }, nil }) }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Apr 24 18:25:29 UTC 2024 - 24.4K bytes - Viewed (0) -
pkg/apis/core/v1/conversion.go
} // If both fields (v1.PodIPs and v1.PodIP) are provided and differ, then PodIP is authoritative for compatibility with older kubelets if (len(in.PodIP) > 0 && len(in.PodIPs) > 0) && (in.PodIP != in.PodIPs[0].IP) { out.PodIPs = []core.PodIP{ { IP: in.PodIP, }, } } // at the this point, autoConvert copied v1.PodIPs -> core.PodIPs // if v1.PodIPs was empty but v1.PodIP is not, then set core.PodIPs[0] with v1.PodIP
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri Apr 19 22:30:55 UTC 2024 - 19K bytes - Viewed (0) -
pkg/controller/replicaset/replica_set_test.go
podExp, exists, err = manager.expectations.GetExpectations(rsKey) if !exists || err != nil || podExp.Fulfilled() { t.Fatalf("Wrong expectations %#v", podExp) } // A pod with a non-nil deletion timestamp should also be ignored by the // delete handler, because it's already been counted in the update. manager.deletePod(logger, &pod)
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat May 04 18:33:12 UTC 2024 - 69.2K bytes - Viewed (0) -
pkg/controller/endpointslice/endpointslice_controller_test.go
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Jun 04 08:33:32 UTC 2024 - 65.5K bytes - Viewed (0) -
cni/pkg/nodeagent/server_test.go
Name: "test", Namespace: "test", UID: types.UID("test"), }, } fakeCtx := context.Background() fakeClientSet := fake.NewSimpleClientset(pod) podIP := netip.MustParseAddr("99.9.9.1") podIPs := []netip.Addr{podIP} server := &fakeServer{} server.On("AddPodToMesh", fakeCtx, pod, podIPs, "", ).Return(nil) server.Start(fakeCtx) m := meshDataplane{
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Fri Jan 26 20:34:28 UTC 2024 - 7.8K bytes - Viewed (0) -
pkg/kube/krt/bench_test.go
Workloads := krt.NewCollection(Pods, func(ctx krt.HandlerContext, p *v1.Pod) *Workload { if p.Status.PodIP == "" { return nil } services := krt.Fetch(ctx, Services, krt.FilterIndex(ServicesByNamespace, p.Namespace), krt.FilterSelectsNonEmpty(p.GetLabels())) return &Workload{ Named: krt.NewNamed(p), IP: p.Status.PodIP, ServiceNames: slices.Map(services, func(e *v1.Service) string { return e.Name }), } })
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Tue Apr 09 19:55:53 UTC 2024 - 7K bytes - Viewed (0) -
pilot/pkg/serviceregistry/serviceregistry_test.go
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Thu May 23 21:07:03 UTC 2024 - 51.2K bytes - Viewed (0) -
cni/pkg/util/podutil.go
return nil } return err } // Get any IPs currently assigned to the Pod. // // If 'PodIPs' exists, it is preferred (and should be guaranteed to contain the address in 'PodIP'), // otherwise fallback to 'PodIP'. // // Note that very early in the pod's lifecycle (before all the node CNI plugin invocations finish) // K8S may not have received the pod IPs yet, and may not report the pod as having any.
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Fri May 31 17:18:11 UTC 2024 - 4.4K bytes - Viewed (0) -
pilot/pkg/controllers/untaint/nodeuntainter_test.go
pod.Status = corev1.PodStatus{} newPod := s.pc.Create(pod) if markReady { setPodReady(newPod) } newPod.Status.PodIP = ip newPod.Status.Phase = corev1.PodRunning newPod.Status.PodIPs = []corev1.PodIP{ { IP: ip, }, } s.pc.UpdateStatus(newPod) } else { s.pc.Update(pod) } }
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Sat Apr 13 00:50:31 UTC 2024 - 6.1K bytes - Viewed (0)