Search Options

Results per page
Sort
Preferred Languages
Advance

Results 11 - 20 of 372 for claim (0.05 sec)

  1. pkg/kubelet/cm/dra/manager.go

    	err := m.cache.withLock(func() error {
    		// Mark all pod claims as prepared.
    		for _, claim := range resourceClaims {
    			info, exists := m.cache.get(claim.Name, claim.Namespace)
    			if !exists {
    				return fmt.Errorf("unable to get claim info for claim %s in namespace %s", claim.Name, claim.Namespace)
    			}
    			info.setPrepared()
    		}
    
    		// Checkpoint to ensure all prepared claims are tracked with their list
    		// of CDI devices attached.
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Fri May 03 13:23:29 UTC 2024
    - 19.4K bytes
    - Viewed (0)
  2. pkg/apis/resource/validation/validation_resourceclaim_test.go

    				return claim
    			}(),
    		},
    		"uid": {
    			claim: func() *resource.ResourceClaim {
    				claim := testClaim(goodName, goodNS, goodClaimSpec)
    				claim.UID = "ac051fac-2ead-46d9-b8b4-4e0fbeb7455d"
    				return claim
    			}(),
    		},
    		"resource-version": {
    			claim: func() *resource.ResourceClaim {
    				claim := testClaim(goodName, goodNS, goodClaimSpec)
    				claim.ResourceVersion = "1"
    				return claim
    			}(),
    		},
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Fri Jun 07 09:18:10 UTC 2024
    - 28.7K bytes
    - Viewed (0)
  3. pkg/kubelet/cm/dra/claiminfo.go

    	if len(resourceHandles) == 0 {
    		resourceHandles = make([]resourcev1alpha2.ResourceHandle, 1)
    	}
    	claimInfoState := state.ClaimInfoState{
    		DriverName:      claim.Status.DriverName,
    		ClassName:       claim.Spec.ResourceClassName,
    		ClaimUID:        claim.UID,
    		ClaimName:       claim.Name,
    		Namespace:       claim.Namespace,
    		PodUIDs:         sets.New[string](),
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Fri May 03 13:30:31 UTC 2024
    - 7.9K bytes
    - Viewed (0)
  4. pkg/controller/statefulset/stateful_pod_control_test.go

    			for k := range claims0 {
    				claim, err := claimLister.PersistentVolumeClaims(claims0[k].Namespace).Get(claims0[k].Name)
    				if err != nil {
    					t.Errorf("Unexpected error getting Claim %s/%s: %v", claim.Namespace, claim.Name, err)
    				}
    				if hasOwnerRef(claim, set) != expectRef {
    					t.Errorf("%s: Claim %s/%s bad set owner ref", tc.name, claim.Namespace, claim.Name)
    				}
    			}
    		}
    	}
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Wed Jun 05 19:06:41 UTC 2024
    - 35.5K bytes
    - Viewed (0)
  5. pkg/scheduler/framework/plugins/dynamicresources/dynamicresources.go

    		claim = claim.DeepCopy()
    		claim.Finalizers = append(claim.Finalizers, resourcev1alpha2.Finalizer)
    		claim.Status.DriverName = driverName
    		claim.Status.Allocation = allocation
    		pl.inFlightAllocations.Store(claim.UID, claim)
    		logger.V(5).Info("Reserved resource in allocation result", "claim", klog.KObj(claim), "driver", driverName, "allocation", klog.Format(allocation))
    	}
    
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Thu May 30 15:22:37 UTC 2024
    - 75.9K bytes
    - Viewed (0)
  6. pkg/controller/volume/persistentvolume/pv_controller_base.go

    func (ctrl *PersistentVolumeController) deleteClaim(ctx context.Context, claim *v1.PersistentVolumeClaim) {
    	logger := klog.FromContext(ctx)
    	if err := ctrl.claims.Delete(claim); err != nil {
    		logger.Error(err, "Claim deletion encountered", "PVC", klog.KObj(claim))
    	}
    	claimKey := claimToClaimKey(claim)
    	logger.V(4).Info("Claim deleted", "PVC", klog.KObj(claim))
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Fri May 10 08:42:31 UTC 2024
    - 29.5K bytes
    - Viewed (0)
  7. pkg/controller/statefulset/stateful_set_utils.go

    	templates := set.Spec.VolumeClaimTemplates
    	claims := make(map[string]v1.PersistentVolumeClaim, len(templates))
    	for i := range templates {
    		claim := templates[i].DeepCopy()
    		claim.Name = getPersistentVolumeClaimName(set, claim, ordinal)
    		claim.Namespace = set.Namespace
    		if claim.Labels != nil {
    			for key, value := range set.Spec.Selector.MatchLabels {
    				claim.Labels[key] = value
    			}
    		} else {
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Wed Jun 05 19:06:41 UTC 2024
    - 26.7K bytes
    - Viewed (0)
  8. staging/src/k8s.io/apiserver/pkg/apis/apiserver/v1alpha1/types.go

    	// Either claim or expression must be set.
    	// Mutually exclusive with expression.
    	// +optional
    	Claim string `json:"claim,omitempty"`
    
    	// expression represents the expression which will be evaluated by CEL.
    	//
    	// CEL expressions have access to the contents of the token claims, organized into CEL variable:
    	// - 'claims' is a map of claim names to claim values.
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Fri Mar 08 17:59:05 UTC 2024
    - 26.6K bytes
    - Viewed (0)
  9. pkg/controller/volume/persistentvolume/pv_controller.go

    		return ctrl.syncUnboundClaim(ctx, claim)
    	} else {
    		return ctrl.syncBoundClaim(ctx, claim)
    	}
    }
    
    // checkVolumeSatisfyClaim checks if the volume requested by the claim satisfies the requirements of the claim
    func checkVolumeSatisfyClaim(volume *v1.PersistentVolume, claim *v1.PersistentVolumeClaim) error {
    	requestedQty := claim.Spec.Resources.Requests[v1.ResourceName(v1.ResourceStorage)]
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Fri May 10 08:42:31 UTC 2024
    - 89.2K bytes
    - Viewed (0)
  10. staging/src/k8s.io/apiserver/pkg/authentication/cel/interface.go

    }
    
    // ClaimsMapper provides a CEL expression mapper configured with the claims CEL variable.
    type ClaimsMapper interface {
    	// EvalClaimMapping evaluates the given claim mapping expression and returns a EvaluationResult.
    	// This is used for username, groups and uid claim mapping that contains a single expression.
    	EvalClaimMapping(ctx context.Context, claims *unstructured.Unstructured) (EvaluationResult, error)
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Fri Mar 08 17:59:05 UTC 2024
    - 5.2K bytes
    - Viewed (0)
Back to top