Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 59 for deletedPod (0.2 sec)

  1. pkg/controller/volume/pvcprotection/pvc_protection_controller_test.go

    		}
    		switch {
    		case test.deletedPod != nil && test.updatedPod != nil && test.deletedPod.Namespace == test.updatedPod.Namespace && test.deletedPod.Name == test.updatedPod.Name:
    			ctrl.podAddedDeletedUpdated(logger, test.deletedPod, test.updatedPod, false)
    		case test.updatedPod != nil:
    			ctrl.podAddedDeletedUpdated(logger, nil, test.updatedPod, false)
    		case test.deletedPod != nil:
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Wed Jul 12 12:57:29 UTC 2023
    - 15.5K bytes
    - Viewed (0)
  2. pkg/scheduler/framework/plugins/nodeports/node_ports.go

    		return framework.QueueSkip, nil
    	}
    
    	logger.V(4).Info("the deleted pod and the target pod have any common port(s), returning Queue as deleting this Pod may make the Pod schedulable", "pod", klog.KObj(pod), "deletedPod", klog.KObj(deletedPod))
    	return framework.Queue, nil
    }
    
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Tue Mar 26 10:53:29 UTC 2024
    - 7.5K bytes
    - Viewed (0)
  3. pkg/scheduler/framework/plugins/nodevolumelimits/csi.go

    	deletedPod, _, err := util.As[*v1.Pod](oldObj, newObj)
    	if err != nil {
    		return framework.Queue, fmt.Errorf("unexpected objects in isSchedulableAfterPodDeleted: %w", err)
    	}
    
    	if len(deletedPod.Spec.Volumes) == 0 {
    		return framework.QueueSkip, nil
    	}
    
    	if deletedPod.Spec.NodeName == "" {
    		return framework.QueueSkip, nil
    	}
    
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Tue May 14 18:07:11 UTC 2024
    - 16.6K bytes
    - Viewed (0)
  4. pkg/scheduler/framework/plugins/nodevolumelimits/csi_test.go

    			if !test.deletedPodNotScheduled {
    				test.deletedPod.Spec.NodeName = node.Node().Name
    			} else {
    				test.deletedPod.Spec.NodeName = ""
    			}
    
    			p := &CSILimits{
    				randomVolumeIDPrefix: rand.String(32),
    				translator:           csitrans.New(),
    			}
    			logger, _ := ktesting.NewTestContext(t)
    			qhint, err := p.isSchedulableAfterPodDeleted(logger, test.newPod, test.deletedPod, nil)
    			if err != nil {
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Tue May 14 18:07:11 UTC 2024
    - 28.6K bytes
    - Viewed (0)
  5. pkg/serviceaccount/claims_test.go

    			deletedServiceAccount = serviceAccount.DeepCopy()
    			deletedPod            = pod.DeepCopy()
    			deletedSecret         = secret.DeepCopy()
    			deletedNode           = node.DeepCopy()
    		)
    		deletedServiceAccount.DeletionTimestamp = deletionTestCase.time
    		deletedPod.DeletionTimestamp = deletionTestCase.time
    		deletedSecret.DeletionTimestamp = deletionTestCase.time
    		deletedNode.DeletionTimestamp = deletionTestCase.time
    
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Wed Apr 24 18:25:29 UTC 2024
    - 17.9K bytes
    - Viewed (0)
  6. pkg/registry/core/pod/storage/eviction.go

    		if err != nil {
    			return err
    		}
    		deletedPod = true
    		return nil
    	})
    	switch {
    	case err != nil:
    		// this can happen in cases where the PDB can be ignored, but there was a problem issuing the pod delete:
    		// maybe we conflicted too many times or we didn't have permission or something else weird.
    		return nil, err
    
    	case deletedPod:
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Tue Aug 08 11:58:48 UTC 2023
    - 18.2K bytes
    - Viewed (0)
  7. pkg/kubelet/config/config_test.go

    	// mark this pod as deleted
    	timestamp := metav1.NewTime(time.Now())
    	deletedPod := CreateValidPod("foo", "new")
    	deletedPod.ObjectMeta.DeletionTimestamp = &timestamp
    	podUpdate = CreatePodUpdate(kubetypes.DELETE, TestSource, deletedPod)
    	channel <- podUpdate
    	// the existing pod should be gracefully deleted
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Tue Jun 04 06:25:43 UTC 2024
    - 17.1K bytes
    - Viewed (0)
  8. pkg/scheduler/framework/plugins/podtopologyspread/plugin.go

    			"pod", klog.KObj(pod), "deletedPod", klog.KObj(originalPod))
    		return framework.Queue, nil
    	}
    	logger.V(5).Info("a scheduled pod was deleted, but it's unrelated to the pod's topology spread constraints",
    		"pod", klog.KObj(pod), "deletedPod", klog.KObj(originalPod))
    
    	return framework.QueueSkip, nil
    }
    
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Sat Mar 16 14:13:06 UTC 2024
    - 12.7K bytes
    - Viewed (0)
  9. pkg/registry/core/pod/storage/storage_test.go

    	}
    	deletedPod, ok := obj.(*api.Pod)
    	if !ok {
    		t.Fatalf("expect a pod is returned")
    	}
    	if deletedPod.DeletionTimestamp == nil {
    		t.Errorf("expect the DeletionTimestamp to be set")
    	}
    	if deletedPod.DeletionGracePeriodSeconds == nil {
    		t.Fatalf("expect the DeletionGracePeriodSeconds to be set")
    	}
    	if *deletedPod.DeletionGracePeriodSeconds != 0 {
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Thu Feb 29 07:18:44 UTC 2024
    - 38.8K bytes
    - Viewed (0)
  10. pkg/scheduler/framework/plugins/noderesources/fit.go

    			logger.V(5).Info("the deleted pod was unscheduled and it wouldn't make the unscheduled pod schedulable", "pod", klog.KObj(pod), "deletedPod", klog.KObj(originalPod))
    			return framework.QueueSkip, nil
    		}
    		logger.V(5).Info("another scheduled pod was deleted, and it may make the unscheduled pod schedulable", "pod", klog.KObj(pod), "deletedPod", klog.KObj(originalPod))
    		return framework.Queue, nil
    	}
    
    	if !f.enableInPlacePodVerticalScaling {
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Wed Jun 12 13:26:09 UTC 2024
    - 20.2K bytes
    - Viewed (0)
Back to top