- Sort Score
- Result 10 results
- Languages All
Results 11 - 20 of 111 for oldpod (4.55 sec)
-
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) -
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) -
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) -
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) -
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) -
pkg/registry/core/pod/strategy_test.go
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Apr 24 18:25:29 UTC 2024 - 76.2K bytes - Viewed (0) -
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) -
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) -
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) -
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)