Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 5 of 5 for claimStatus (1.11 sec)

  1. pkg/apis/resource/validation/validation.go

    	var allErrs field.ErrorList
    	names := sets.NewString()
    	for i, claimStatus := range claimStatuses {
    		allErrs = append(allErrs, validatePodSchedulingClaim(claimStatus, fldPath.Index(i))...)
    		if names.Has(claimStatus.Name) {
    			allErrs = append(allErrs, field.Duplicate(fldPath.Index(i), claimStatus.Name))
    		} else {
    			names.Insert(claimStatus.Name)
    		}
    	}
    	return allErrs
    }
    
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Fri Jun 07 09:18:10 UTC 2024
    - 28.3K bytes
    - Viewed (0)
  2. pkg/scheduler/framework/plugins/dynamicresources/structuredparameters_test.go

    	}
    
    	for name, tc := range testcases {
    		t.Run(name, func(t *testing.T) {
    			tCtx := ktesting.Init(t)
    
    			var inFlightAllocations sync.Map
    			for uid, claimStatus := range tc.inFlight {
    				inFlightAllocations.Store(uid, &resourceapi.ResourceClaim{Status: claimStatus})
    			}
    
    			slices := tc.slices
    			if slices == nil {
    				slices = sliceList{}
    			}
    			claims := tc.claims
    			if claims == nil {
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Wed Mar 27 09:27:01 UTC 2024
    - 34.8K bytes
    - Viewed (0)
  3. pkg/scheduler/framework/plugins/dynamicresources/dynamicresources.go

    	if podScheduling.Spec.SelectedNode != "" {
    		for _, claimStatus := range podScheduling.Status.ResourceClaims {
    			if slices.Contains(claimStatus.UnsuitableNodes, podScheduling.Spec.SelectedNode) {
    				logger.V(5).Info("PodSchedulingContext has unsuitable selected node, schedule immediately", "pod", klog.KObj(pod), "selectedNode", podScheduling.Spec.SelectedNode, "podResourceName", claimStatus.Name)
    				return framework.Queue, nil
    			}
    		}
    	}
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Thu May 30 15:22:37 UTC 2024
    - 75.9K bytes
    - Viewed (0)
  4. pkg/controller/volume/persistentvolume/pv_controller.go

    func (ctrl *PersistentVolumeController) syncClaim(ctx context.Context, claim *v1.PersistentVolumeClaim) error {
    	logger := klog.FromContext(ctx)
    	logger.V(4).Info("Synchronizing PersistentVolumeClaim", "PVC", klog.KObj(claim), "claimStatus", getClaimStatusForLogging(claim))
    
    	// Set correct "migrated-to" annotations on PVC and update in API server if
    	// necessary
    	newClaim, err := ctrl.updateClaimMigrationAnnotations(ctx, claim)
    	if err != nil {
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Fri May 10 08:42:31 UTC 2024
    - 89.2K bytes
    - Viewed (0)
  5. pkg/controller/statefulset/stateful_pod_control_test.go

    	testCases := []struct {
    		name        string
    		claimStates []string
    		expected    bool
    		skipPodUID  bool
    	}{
    		{
    			name:        "all missing",
    			claimStates: []string{missing, missing},
    			expected:    false,
    		},
    		{
    			name:        "no claims",
    			claimStates: []string{},
    			expected:    false,
    		},
    		{
    			name:        "exists",
    			claimStates: []string{missing, exists},
    			expected:    false,
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Wed Jun 05 19:06:41 UTC 2024
    - 35.5K bytes
    - Viewed (0)
Back to top