Search Options

Results per page
Sort
Preferred Languages
Advance

Results 11 - 20 of 144 for oldpod (0.2 sec)

  1. pkg/controller/statefulset/stateful_set.go

    	curPod := cur.(*v1.Pod)
    	oldPod := old.(*v1.Pod)
    	if curPod.ResourceVersion == oldPod.ResourceVersion {
    		// In the event of a re-list we may receive update events for all known pods.
    		// Two different versions of the same pod will always have different RVs.
    		return
    	}
    
    	labelChanged := !reflect.DeepEqual(curPod.Labels, oldPod.Labels)
    
    	curControllerRef := metav1.GetControllerOf(curPod)
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Wed Jun 05 19:06:41 UTC 2024
    - 18.5K bytes
    - Viewed (0)
  2. 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)
  3. pkg/controller/tainteviction/taint_eviction.go

    func (tc *Controller) PodUpdated(oldPod *v1.Pod, newPod *v1.Pod) {
    	podName := ""
    	podNamespace := ""
    	nodeName := ""
    	oldTolerations := []v1.Toleration{}
    	if oldPod != nil {
    		podName = oldPod.Name
    		podNamespace = oldPod.Namespace
    		nodeName = oldPod.Spec.NodeName
    		oldTolerations = oldPod.Spec.Tolerations
    	}
    	newTolerations := []v1.Toleration{}
    	if newPod != nil {
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Sat May 04 18:33:12 UTC 2024
    - 19.9K bytes
    - Viewed (0)
  4. 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)
  5. pkg/controller/replicaset/replica_set.go

    	curPod := cur.(*v1.Pod)
    	oldPod := old.(*v1.Pod)
    	if curPod.ResourceVersion == oldPod.ResourceVersion {
    		// Periodic resync will send update events for all known pods.
    		// Two different versions of the same pod will always have different RVs.
    		return
    	}
    
    	labelChanged := !reflect.DeepEqual(curPod.Labels, oldPod.Labels)
    	if curPod.DeletionTimestamp != nil {
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Sat May 04 18:33:12 UTC 2024
    - 33.2K bytes
    - Viewed (0)
  6. pkg/kubelet/pleg/generic.go

    		fillCidSet(p.Sandboxes)
    	}
    	return containers
    }
    
    func computeEvents(oldPod, newPod *kubecontainer.Pod, cid *kubecontainer.ContainerID) []*PodLifecycleEvent {
    	var pid types.UID
    	if oldPod != nil {
    		pid = oldPod.ID
    	} else if newPod != nil {
    		pid = newPod.ID
    	}
    	oldState := getContainerState(oldPod, cid)
    	newState := getContainerState(newPod, cid)
    	return generateEvents(pid, cid.ID, oldState, newState)
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Tue Jun 04 06:25:43 UTC 2024
    - 19.3K bytes
    - Viewed (0)
  7. pkg/scheduler/internal/cache/cache.go

    		cache.assumedPods.Insert(key)
    	}
    	return nil
    }
    
    // Assumes that lock is already acquired.
    func (cache *cacheImpl) updatePod(logger klog.Logger, oldPod, newPod *v1.Pod) error {
    	if err := cache.removePod(logger, oldPod); err != nil {
    		return err
    	}
    	return cache.addPod(logger, newPod, false)
    }
    
    // Assumes that lock is already acquired.
    // Removes a pod from the cached node info. If the node information was already
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Tue Oct 24 09:56:48 UTC 2023
    - 24.9K bytes
    - Viewed (0)
  8. pkg/scheduler/internal/queue/scheduling_queue.go

    }
    
    // UpdateNominatedPod updates the <oldPod> with <newPod>.
    func (npm *nominator) UpdateNominatedPod(logger klog.Logger, oldPod *v1.Pod, newPodInfo *framework.PodInfo) {
    	npm.lock.Lock()
    	defer npm.lock.Unlock()
    	npm.updateNominatedPodUnlocked(logger, oldPod, newPodInfo)
    }
    
    func (npm *nominator) updateNominatedPodUnlocked(logger klog.Logger, oldPod *v1.Pod, newPodInfo *framework.PodInfo) {
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Wed Jun 12 13:26:09 UTC 2024
    - 61.4K bytes
    - Viewed (0)
  9. pkg/kubelet/pod/pod_manager.go

    }
    
    func (pm *basicManager) AddPod(pod *v1.Pod) {
    	pm.UpdatePod(pod)
    }
    
    func (pm *basicManager) UpdatePod(pod *v1.Pod) {
    	pm.lock.Lock()
    	defer pm.lock.Unlock()
    	pm.updatePodsInternal(pod)
    }
    
    // updateMetrics updates the metrics surfaced by the pod manager.
    // oldPod or newPod may be nil to signify creation or deletion.
    func updateMetrics(oldPod, newPod *v1.Pod) {
    	var numEC int
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Fri Mar 01 06:06:00 UTC 2024
    - 11.9K bytes
    - Viewed (0)
  10. 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)
Back to top