Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 36 for oldpod (0.1 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. 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)
  8. 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)
  9. 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)
  10. 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)
Back to top