Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 65 for oldpod (0.14 sec)

  1. 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)
  2. 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)
  3. 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)
  4. 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)
  5. 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)
  6. 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)
  7. 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)
  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/registry/core/pod/strategy_test.go

    				t.Errorf("unexpected error:%v", errs)
    			}
    		})
    	}
    
    	test = []struct {
    		name   string
    		newPod *api.Pod
    		oldPod *api.Pod
    	}{
    		{
    			name: "add ephemeral container to static pod and expect failure",
    			oldPod: &api.Pod{
    				ObjectMeta: metav1.ObjectMeta{
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Wed Apr 24 18:25:29 UTC 2024
    - 76.2K bytes
    - Viewed (0)
  10. pkg/controller/volume/pvcprotection/pvc_protection_controller.go

    		// where it is blocking deletion of a PVC not referenced by Y, otherwise
    		// such PVC will never be deleted.
    		if oldPod := c.parsePod(old); oldPod != nil && oldPod.UID != pod.UID {
    			c.enqueuePVCs(logger, oldPod, true)
    		}
    	}
    }
    
    func (*Controller) parsePod(obj interface{}) *v1.Pod {
    	if obj == nil {
    		return nil
    	}
    	pod, ok := obj.(*v1.Pod)
    	if !ok {
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Sat May 04 18:33:12 UTC 2024
    - 14K bytes
    - Viewed (0)
Back to top