- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 32 for oldpod (0.16 sec)
-
pkg/scheduler/framework/plugins/interpodaffinity/plugin_test.go
oldPod: st.MakePod().Node("fake-node").Label("service", "bbb").Obj(), expectedHint: framework.QueueSkip, }, { name: "delete a pod which doesn't match pod's anti-affinity", pod: st.MakePod().Name("p").PodAntiAffinityIn("service", "region", []string{"securityscan", "value2"}, st.PodAntiAffinityWithRequiredReq).Obj(),
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri Apr 12 03:08:44 UTC 2024 - 9.7K bytes - Viewed (0) -
plugin/pkg/auth/authorizer/node/graph_populator.go
} func (g *graphPopulator) addPod(obj interface{}) { g.updatePod(nil, obj) } func (g *graphPopulator) updatePod(oldObj, obj interface{}) { pod := obj.(*corev1.Pod) if len(pod.Spec.NodeName) == 0 { // No node assigned klog.V(5).Infof("updatePod %s/%s, no node", pod.Namespace, pod.Name) return } if oldPod, ok := oldObj.(*corev1.Pod); ok && oldPod != nil {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu Mar 07 21:22:55 UTC 2024 - 6.5K bytes - Viewed (0) -
pkg/controller/job/tracking_utils_test.go
}, wantDelete: 1, }, "pod without finalizer removed": { oldPod: &v1.Pod{ Status: v1.PodStatus{ Phase: v1.PodSucceeded, }, }, }, } for name, tc := range cases { t.Run(name, func(t *testing.T) { metrics.TerminatedPodsTrackingFinalizerTotal.Reset() recordFinishedPodWithTrackingFinalizer(tc.oldPod, tc.newPod)
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Jun 14 05:40:02 UTC 2023 - 5.9K bytes - Viewed (0) -
pkg/quota/v1/install/update_filter.go
return func(resource schema.GroupVersionResource, oldObj, newObj interface{}) bool { switch resource.GroupResource() { case schema.GroupResource{Resource: "pods"}: oldPod := oldObj.(*v1.Pod) newPod := newObj.(*v1.Pod) return core.QuotaV1Pod(oldPod, clock.RealClock{}) && !core.QuotaV1Pod(newPod, clock.RealClock{}) case schema.GroupResource{Resource: "services"}: oldService := oldObj.(*v1.Service)
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri Jul 08 22:39:55 UTC 2022 - 1.7K bytes - Viewed (0) -
plugin/pkg/admission/priority/admission.go
if pod.Spec.Priority == nil && oldPod.Spec.Priority != nil { pod.Spec.Priority = oldPod.Spec.Priority } if pod.Spec.PreemptionPolicy == nil && oldPod.Spec.PreemptionPolicy != nil { pod.Spec.PreemptionPolicy = oldPod.Spec.PreemptionPolicy } return nil } if operation == admission.Create { var priority int32
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Feb 08 10:11:23 UTC 2022 - 9K bytes - Viewed (0) -
pkg/controller/job/tracking_utils.go
for _, fin := range pod.Finalizers { if fin == batch.JobTrackingFinalizer { return true } } return false } func recordFinishedPodWithTrackingFinalizer(oldPod, newPod *v1.Pod) { was := isFinishedPodWithTrackingFinalizer(oldPod) is := isFinishedPodWithTrackingFinalizer(newPod) if was == is { return } var event = metrics.Delete if is { event = metrics.Add }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Jun 14 05:40:02 UTC 2023 - 4.3K bytes - Viewed (0) -
pkg/scheduler/internal/cache/fake/fake_cache.go
func (c *Cache) ForgetPod(logger klog.Logger, pod *v1.Pod) error { c.ForgetFunc(pod) return nil } // AddPod is a fake method for testing. func (c *Cache) AddPod(logger klog.Logger, pod *v1.Pod) error { return nil } // UpdatePod is a fake method for testing. func (c *Cache) UpdatePod(logger klog.Logger, oldPod, newPod *v1.Pod) error { return nil } // RemovePod is a fake method for testing.
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Mon May 29 05:26:32 UTC 2023 - 2.8K bytes - Viewed (0) -
pkg/scheduler/internal/cache/interface.go
ForgetPod(logger klog.Logger, pod *v1.Pod) error // AddPod either confirms a pod if it's assumed, or adds it back if it's expired. // If added back, the pod's information would be added again. AddPod(logger klog.Logger, pod *v1.Pod) error // UpdatePod removes oldPod's information and adds newPod's information. UpdatePod(logger klog.Logger, oldPod, newPod *v1.Pod) error
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Mon May 29 05:26:32 UTC 2023 - 5.2K bytes - Viewed (0) -
pkg/kubelet/container/runtime_cache_test.go
} func TestForceUpdateIfOlder(t *testing.T) { ctx := context.Background() runtime := &ctest.FakeRuntime{} cache := NewTestRuntimeCache(runtime) // Cache old pods. oldpods := []*ctest.FakePod{{Pod: &Pod{ID: "1111"}}} runtime.PodList = oldpods cache.UpdateCacheWithLock() // Update the runtime to new pods. newpods := []*ctest.FakePod{{Pod: &Pod{ID: "1111"}}, {Pod: &Pod{ID: "2222"}}, {Pod: &Pod{ID: "3333"}}}
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat Nov 05 13:02:13 UTC 2022 - 2.2K bytes - Viewed (0) -
pkg/registry/core/node/strategy_test.go
old := tc.oldNode.DeepCopy() // old node should never be changed if !reflect.DeepEqual(tc.oldNode, old) { t.Errorf("%v: old node changed: %v", tc.name, cmp.Diff(tc.oldNode, old)) } if !reflect.DeepEqual(tc.node, tc.compareNode) { t.Errorf("%v: unexpected node spec: %v", tc.name, cmp.Diff(tc.node, tc.compareNode)) } }() } } func TestValidateUpdate(t *testing.T) {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Apr 12 15:48:03 UTC 2023 - 9.7K bytes - Viewed (0)