- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 65 for oldpod (0.14 sec)
-
pkg/api/pod/util_test.go
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed May 29 22:40:29 UTC 2024 - 108.8K bytes - Viewed (0) -
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) -
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) -
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) -
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) -
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/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/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)