Search Options

Results per page
Sort
Preferred Languages
Advance

Results 11 - 20 of 93 for oldpod (2.07 sec)

  1. 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)
  2. 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)
  3. 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)
  4. 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)
  5. 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)
  6. pkg/api/pod/warnings.go

    	"k8s.io/kubernetes/pkg/features"
    )
    
    func GetWarningsForPod(ctx context.Context, pod, oldPod *api.Pod) []string {
    	if pod == nil {
    		return nil
    	}
    
    	var (
    		oldSpec *api.PodSpec
    		oldMeta *metav1.ObjectMeta
    	)
    	if oldPod != nil {
    		oldSpec = &oldPod.Spec
    		oldMeta = &oldPod.ObjectMeta
    	}
    	return warningsForPodSpecAndMeta(nil, &pod.Spec, &pod.ObjectMeta, oldSpec, oldMeta)
    }
    
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Thu Mar 07 17:51:48 UTC 2024
    - 16.6K bytes
    - Viewed (0)
  7. pkg/apis/core/validation/validation.go

    			allErrs = append(allErrs, validateNodeSelectorMutation(specPath.Child("nodeSelector"), mungedPodSpec.NodeSelector, oldPod.Spec.NodeSelector)...)
    			mungedPodSpec.NodeSelector = oldPod.Spec.NodeSelector // +k8s:verify-mutation:reason=clone
    		}
    
    		// Validate node affinity mutations.
    		var oldNodeAffinity *core.NodeAffinity
    		if oldPod.Spec.Affinity != nil {
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Wed May 29 22:40:29 UTC 2024
    - 349.5K bytes
    - Viewed (0)
  8. pkg/api/pod/util.go

    	)
    	if pod != nil {
    		podSpec = &pod.Spec
    		podStatus = &pod.Status
    		podAnnotations = pod.Annotations
    	}
    	if oldPod != nil {
    		oldPodSpec = &oldPod.Spec
    		oldPodStatus = &oldPod.Status
    		oldPodAnnotations = oldPod.Annotations
    	}
    	dropDisabledFields(podSpec, podAnnotations, oldPodSpec, oldPodAnnotations)
    	dropDisabledPodStatusFields(podStatus, oldPodStatus, podSpec, oldPodSpec)
    }
    
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Wed May 29 22:40:29 UTC 2024
    - 41.3K bytes
    - Viewed (0)
  9. pkg/controller/daemon/daemon_controller.go

    func shouldIgnoreNodeUpdate(oldNode, curNode v1.Node) bool {
    	return apiequality.Semantic.DeepEqual(oldNode.Labels, curNode.Labels) &&
    		apiequality.Semantic.DeepEqual(oldNode.Spec.Taints, curNode.Spec.Taints)
    }
    
    func (dsc *DaemonSetsController) updateNode(logger klog.Logger, old, cur interface{}) {
    	oldNode := old.(*v1.Node)
    	curNode := cur.(*v1.Node)
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Sat May 04 18:33:12 UTC 2024
    - 51.3K bytes
    - Viewed (0)
  10. plugin/pkg/admission/noderestriction/admission.go

    		}
    
    		// make copies for comparison
    		oldPVC = oldPVC.DeepCopy()
    		newPVC = newPVC.DeepCopy()
    
    		// zero out resourceVersion to avoid comparing differences,
    		// since the new object could leave it empty to indicate an unconditional update
    		oldPVC.ObjectMeta.ResourceVersion = ""
    		newPVC.ObjectMeta.ResourceVersion = ""
    
    		oldPVC.Status.Capacity = nil
    		newPVC.Status.Capacity = nil
    
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Thu Mar 07 21:22:55 UTC 2024
    - 23.6K bytes
    - Viewed (0)
Back to top