- Sort Score
- Result 10 results
- Languages All
Results 81 - 90 of 1,389 for podIps (0.34 sec)
-
pkg/kube/krt/index_test.go
ObjectMeta: metav1.ObjectMeta{ Name: "name", Namespace: "namespace", }, Status: corev1.PodStatus{PodIP: "1.2.3.4"}, } pc.CreateOrUpdateStatus(pod) tt.WaitUnordered("add/namespace/name") assert.Equal(t, fetchSorted("1.2.3.4"), []SimplePod{{NewNamed(pod), Labeled{}, "1.2.3.4"}}) pod.Status.PodIP = "1.2.3.5" pc.UpdateStatus(pod) tt.WaitUnordered("update/namespace/name")
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Tue Apr 09 19:55:53 UTC 2024 - 4.5K bytes - Viewed (0) -
staging/src/k8s.io/apiserver/pkg/apis/example/v1/types.go
HostIP string `json:"hostIP,omitempty" protobuf:"bytes,5,opt,name=hostIP"` // IP address allocated to the pod. Routable at least within the cluster. // Empty if not yet allocated. // +optional PodIP string `json:"podIP,omitempty" protobuf:"bytes,6,opt,name=podIP"` // RFC 3339 date and time at which the object was acknowledged by the Kubelet. // This is before the Kubelet pulled the container image(s) for the pod. // +optional
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Feb 20 15:45:02 UTC 2024 - 9.1K bytes - Viewed (0) -
pkg/kube/krt/bench_test.go
} c.pods = kclient.New[*v1.Pod](cl) c.services = kclient.New[*v1.Service](cl) c.queue = controllers.NewQueue("pods", controllers.WithReconciler(c.Reconcile)) c.pods.AddEventHandler(controllers.ObjectHandler(c.queue.AddObject)) c.services.AddEventHandler(controllers.FromEventHandler(func(e controllers.Event) { o := e.Latest()
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Tue Apr 09 19:55:53 UTC 2024 - 7K bytes - Viewed (0) -
pkg/kube/krt/join_test.go
} sec.Create(se) assert.EventuallyEqual(t, fetch, []SimpleEndpoint{ {pod.Name, se.Name, pod.Namespace, pod.Status.PodIP}, {pod2.Name, se.Name, pod2.Namespace, pod2.Status.PodIP}, {pod.Name, svc.Name, pod.Namespace, pod.Status.PodIP}, {pod2.Name, svc.Name, pod2.Namespace, pod2.Status.PodIP}, }) } func TestCollectionJoinSync(t *testing.T) { c := kube.NewFakeClient(&corev1.Pod{
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Tue Apr 09 19:55:53 UTC 2024 - 6.1K bytes - Viewed (0) -
plugin/pkg/auth/authorizer/node/graph_test.go
"node:node3": {}, "pod:ns/pod1": {"node:node1"}, "pod:ns/pod2": {"node:node2"}, "pod:ns/pod3": {"node:node3"}, "configmap:ns/cm1": {"pod:ns/pod1", "pod:ns/pod2", "pod:ns/pod3"}, "configmap:ns/cm2": {"pod:ns/pod1", "pod:ns/pod2", "pod:ns/pod3"}, "configmap:ns/cm3": {"pod:ns/pod1", "pod:ns/pod2", "pod:ns/pod3"},
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri Sep 23 23:14:19 UTC 2022 - 12.3K bytes - Viewed (0) -
pilot/pkg/serviceregistry/kube/controller/pod_test.go
} fx.Clear() } func cleanup(ki kubernetes.Interface) { for _, n := range []string{"nsa", "nsb"} { n := n pods, err := ki.CoreV1().Pods(n).List(context.TODO(), metav1.ListOptions{}) if err == nil { // Make sure the pods don't exist for _, pod := range pods.Items { _ = ki.CoreV1().Pods(pod.Namespace).Delete(context.TODO(), pod.Name, metav1.DeleteOptions{}) } } } }
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Tue Apr 16 18:27:40 UTC 2024 - 12.3K bytes - Viewed (0) -
CHANGELOG/CHANGELOG-1.28.md
Burstable QoS pods. For Best-Effort/Guaranteed QoS pods, swap would be disabled. Containers with memory requests equal to their memory limits also won't have swap access, and it is a way to opt-out of swap for a single container. The formula for the swap limit for Burstable QoS pods is: `(<memory-request>/<node-memory-capacity>)*<node-swap-capacity>`.
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Jun 11 23:47:59 UTC 2024 - 408.3K bytes - Viewed (0) -
pkg/registry/core/pod/storage/eviction_test.go
expectError: "Cannot evict pod as it would violate the pod's disruption budget.: TooManyRequests: The disruption budget foo needs 0 healthy pods and has 0 currently", podPhase: api.PodRunning, podName: "t1", policies: []*policyv1.UnhealthyPodEvictionPolicyType{nil, unhealthyPolicyPtr(policyv1.IfHealthyBudget)}, // AlwaysAllow would terminate the pod since Running pods are not guarded by this policy }, {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Jun 12 09:26:37 UTC 2024 - 40K bytes - Viewed (0) -
pkg/kube/controllers/example_test.go
kube.WaitForCacheSync("test", stop, controller.HasSynced) // In a test, we can also use a wrapped client that calls t.Fatal on errors // pods := clienttest.Wrap(t, controller.pods) _, _ = controller.pods.Create(&corev1.Pod{ ObjectMeta: metav1.ObjectMeta{Name: "test2"}, Status: corev1.PodStatus{PodIP: "127.0.0.2"}, }) // There is no guarantee that test2 would be processed before the controller exits, so wait for events insert
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Tue May 23 17:08:31 UTC 2023 - 7K bytes - Viewed (0) -
pkg/kubelet/cm/pod_container_manager_linux.go
func (m *podContainerManagerImpl) GetPodContainerName(pod *v1.Pod) (CgroupName, string) { podQOS := v1qos.GetPodQOS(pod) // Get the parent QOS container name var parentContainer CgroupName switch podQOS { case v1.PodQOSGuaranteed: parentContainer = m.qosContainersInfo.Guaranteed case v1.PodQOSBurstable: parentContainer = m.qosContainersInfo.Burstable
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Mar 14 16:38:36 UTC 2023 - 12.5K bytes - Viewed (0)