Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 32 for oldpod (0.16 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. 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)
  3. 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)
  4. 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)
  5. 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)
  6. 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)
  7. 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)
  8. 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)
  9. 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)
  10. 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)
Back to top