Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 273 for claim (0.05 sec)

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

    						{
    							Name: "test-pod-claim-4",
    							Source: v1.ClaimSource{ResourceClaimName: func() *string {
    								s := "test-pod-claim-4"
    								return &s
    							}()},
    						},
    					},
    					Containers: []v1.Container{
    						{
    							Resources: v1.ResourceRequirements{
    								Claims: []v1.ResourceClaim{
    									{
    										Name: "test-pod-claim-4",
    									},
    								},
    							},
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Fri May 03 13:30:29 UTC 2024
    - 42K bytes
    - Viewed (0)
  2. pkg/controller/resourceclaim/controller_test.go

    	claim = claim.DeepCopy()
    	// As far the controller is concerned, a claim was allocated by us if it has
    	// this finalizer. For testing we don't need to update the allocation result.
    	claim.Finalizers = append(claim.Finalizers, resourcev1alpha2.Finalizer)
    	return claim
    }
    
    func reserveClaim(claim *resourcev1alpha2.ResourceClaim, pod *v1.Pod) *resourcev1alpha2.ResourceClaim {
    	claim = claim.DeepCopy()
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Mon May 06 08:56:16 UTC 2024
    - 28.2K bytes
    - Viewed (0)
  3. pkg/controller/volume/persistentvolume/pv_controller_test.go

    		reactor := newVolumeReactor(ctx, client, ctrl, fakeVolumeWatch, fakeClaimWatch, test.errors)
    		for _, claim := range test.initialClaims {
    			claim = claim.DeepCopy()
    			reactor.AddClaim(claim)
    			go func(claim *v1.PersistentVolumeClaim) {
    				fakeClaimWatch.Add(claim)
    			}(claim)
    		}
    		for _, volume := range test.initialVolumes {
    			volume = volume.DeepCopy()
    			reactor.AddVolume(volume)
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Wed Apr 24 18:25:29 UTC 2024
    - 43.4K bytes
    - Viewed (0)
  4. pkg/controller/volume/persistentvolume/delete_test.go

    				// Bind the volume to resurrected claim (this should never
    				// happen)
    				claim := newClaim("claim8-7", "uid8-7", "10Gi", "volume8-7", v1.ClaimBound, nil)
    				reactor.AddClaimBoundToVolume(claim)
    				ctrl.claims.Add(claim)
    			}),
    		},
    		{
    			// delete success - volume bound by user is deleted, while a new
    			// claim is created with another UID.
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Wed Apr 24 18:25:29 UTC 2024
    - 15.8K bytes
    - Viewed (0)
  5. pkg/scheduler/framework/plugins/dynamicresources/dynamicresources_test.go

    				prebind: result{
    					changes: change{
    						claim: func(claim *resourcev1alpha2.ResourceClaim) *resourcev1alpha2.ResourceClaim {
    							if claim.Name == claimName {
    								claim = claim.DeepCopy()
    								claim.Status.ReservedFor = inUseClaim.Status.ReservedFor
    							}
    							return claim
    						},
    					},
    				},
    			},
    		},
    		"missing-claim": {
    			pod:    podWithClaimTemplate, // status not set
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Mon May 27 07:57:10 UTC 2024
    - 61.9K bytes
    - Viewed (0)
  6. pkg/controller/resourceclaim/controller.go

    				logger.V(5).Info("pod for claim not found", "claim", klog.KObj(claim), "pod", klog.KRef(claim.Namespace, podName))
    			default:
    				return fmt.Errorf("lookup pod: %v", err)
    			}
    		} else {
    			logger.V(5).Info("claim not generated for a pod", "claim", klog.KObj(claim))
    		}
    	}
    
    	return nil
    }
    
    func owningPod(claim *resourcev1alpha2.ResourceClaim) (string, types.UID) {
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Thu May 09 03:34:25 UTC 2024
    - 37.1K bytes
    - Viewed (0)
  7. staging/src/k8s.io/apiserver/plugin/pkg/authenticator/token/oidc/oidc_test.go

    		}
    		return
    	}
    
    	claims := struct{}{}
    	if err := json.Unmarshal([]byte(c.claims), &claims); err != nil {
    		t.Fatalf("failed to unmarshal claims: %v", err)
    	}
    
    	// Sign and serialize the claims in a JWT.
    	jws, err := signer.Sign([]byte(c.claims))
    	if err != nil {
    		t.Fatalf("sign claims: %v", err)
    	}
    	token, err := jws.CompactSerialize()
    	if err != nil {
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Wed Apr 24 18:25:29 UTC 2024
    - 97.7K bytes
    - Viewed (0)
  8. staging/src/k8s.io/apiserver/pkg/apis/apiserver/validation/validation_test.go

    		{
    			name: "duplicate claim",
    			in: []api.ClaimValidationRule{
    				{Claim: "claim"},
    				{Claim: "claim"},
    			},
    			structuredAuthnFeatureEnabled: true,
    			want:                          `issuer.claimValidationRules[1].claim: Duplicate value: "claim"`,
    		},
    		{
    			name: "duplicate expression",
    			in: []api.ClaimValidationRule{
    				{Expression: "claims.foo == 'bar'"},
    				{Expression: "claims.foo == 'bar'"},
    			},
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Fri May 10 22:07:40 UTC 2024
    - 87.2K bytes
    - Viewed (0)
  9. 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)
  10. 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)
Back to top