- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 36 for oldpod (0.1 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) -
plugin/pkg/admission/alwayspullimages/admission_test.go
resource: "pods", subresource: "finalizers", object: pod, oldObject: oldPod, expectIgnore: true, }, { name: "update IfNotPresent pod image", kind: "Pod", resource: "pods", subresource: "finalizers", object: podWithNewImage, oldObject: oldPod, }, } for _, tc := range tests {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Mon Nov 30 22:59:57 UTC 2020 - 8.5K bytes - Viewed (0) -
plugin/pkg/admission/alwayspullimages/admission.go
return false } oldPod, ok := attributes.GetOldObject().(*api.Pod) if !ok { klog.Warningf("Resource was marked with kind Pod but old pod was unable to be converted.") return false } oldImages := sets.NewString() pods.VisitContainersWithPath(&oldPod.Spec, field.NewPath("spec"), func(c *api.Container, _ *field.Path) bool { oldImages.Insert(c.Image)
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Mon Nov 30 22:59:57 UTC 2020 - 5.2K 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)