- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 140 for oldpod (0.14 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) -
pkg/scheduler/framework/plugins/podtopologyspread/plugin_test.go
Obj(), newPod: st.MakePod().Label("foo", "").Obj(), oldPod: st.MakePod().Label("bar", "").Obj(), expectedHint: framework.QueueSkip, }, { name: "delete un-scheduled pod", pod: st.MakePod().Name("p").Label("foo", ""). SpreadConstraint(1, "zone", v1.DoNotSchedule, fooSelector, nil, nil, nil, nil). Obj(), oldPod: st.MakePod().Label("foo", "").Obj(),
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sun Dec 17 06:30:53 UTC 2023 - 13K bytes - Viewed (0) -
pkg/api/pod/util_test.go
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed May 29 22:40:29 UTC 2024 - 108.8K bytes - Viewed (0) -
pkg/controller/daemon/update.go
oldPodsToDelete = append(oldPodsToDelete, oldPod.Name) continue } // the old pod isn't available, allow it to become a replacement logger.V(5).Info("Pod on node is out of date and not available, allowing replacement", "daemonset", klog.KObj(ds), "pod", klog.KObj(oldPod), "node", klog.KRef("", nodeName)) // record the replacement
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Mon May 13 16:53:53 UTC 2024 - 24.4K 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/registry/core/pod/strategy.go
newPod := obj.(*api.Pod) oldPod := old.(*api.Pod) *newPod = *dropNonEphemeralContainerUpdates(newPod, oldPod) podutil.DropDisabledPodFields(newPod, oldPod) } func (podEphemeralContainersStrategy) ValidateUpdate(ctx context.Context, obj, old runtime.Object) field.ErrorList { newPod := obj.(*api.Pod) oldPod := old.(*api.Pod)
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu Mar 07 17:51:48 UTC 2024 - 29.8K bytes - Viewed (0) -
cni/pkg/nodeagent/informers.go
// For update, we just need to handle opt outs newPod := event.New.(*corev1.Pod) oldPod := event.Old.(*corev1.Pod) ns := s.namespaces.Get(newPod.Namespace, "") if ns == nil { return fmt.Errorf("failed to find namespace %v", ns) } wasAnnotated := oldPod.Annotations != nil && oldPod.Annotations[constants.AmbientRedirection] == constants.AmbientRedirectionEnabled
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Thu Jun 06 21:31:35 UTC 2024 - 11.8K bytes - Viewed (0) -
staging/src/k8s.io/apiserver/pkg/admission/conversion_test.go
}{ { Name: "noop", Attrs: &VersionedAttributes{ Attributes: attrs( &example.Pod{ObjectMeta: metav1.ObjectMeta{Name: "newpod"}}, &example.Pod{ObjectMeta: metav1.ObjectMeta{Name: "oldpod"}}, ), VersionedObject: &examplev1.Pod{ObjectMeta: metav1.ObjectMeta{Name: "newpodversioned"}}, VersionedOldObject: &examplev1.Pod{ObjectMeta: metav1.ObjectMeta{Name: "oldpodversioned"}},
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Apr 12 15:48:03 UTC 2023 - 13.7K bytes - Viewed (0) -
pkg/scheduler/eventhandlers.go
return } logger.V(4).Info("Update event for scheduled pod", "pod", klog.KObj(oldPod)) if err := sched.Cache.UpdatePod(logger, oldPod, newPod); err != nil { logger.Error(err, "Scheduler cache UpdatePod failed", "pod", klog.KObj(oldPod)) } sched.SchedulingQueue.AssignedPodUpdated(logger, oldPod, newPod) } func (sched *Scheduler) deletePodFromCache(obj interface{}) { logger := sched.logger
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu Mar 07 21:21:04 UTC 2024 - 24K bytes - Viewed (0)