Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 144 for oldpod (0.15 sec)

  1. 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)
  2. 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)
  3. pkg/api/pod/util_test.go

    					var oldPodSpec *api.PodSpec
    					if oldPod != nil {
    						oldPodSpec = &oldPod.Spec
    					}
    					dropDisabledFields(&newPod.Spec, nil, oldPodSpec, nil)
    
    					// old pod should never be changed
    					if !reflect.DeepEqual(oldPod, oldPodInfo.pod()) {
    						t.Errorf("old pod changed: %v", cmp.Diff(oldPod, oldPodInfo.pod()))
    					}
    
    					switch {
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Wed May 29 22:40:29 UTC 2024
    - 108.8K bytes
    - Viewed (0)
  4. 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)
  5. 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)
  6. 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)
  7. 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)
  8. 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)
  9. 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)
  10. 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)
Back to top