- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 766 for claim (0.05 sec)
-
pkg/controller/volume/persistentvolume/binder_test.go
// volume.Spec.ClaimRef.UID. Check that the claim is marked as lost. name: "3-4 - bound claim with prebound volume", initialVolumes: newVolumeArray("volume3-4", "10Gi", "claim3-4-x", "claim3-4", v1.VolumeAvailable, v1.PersistentVolumeReclaimRetain, classEmpty),
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Mar 14 00:37:30 UTC 2023 - 65.8K bytes - Viewed (0) -
pkg/kubelet/cm/dra/manager_test.go
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri May 03 13:30:29 UTC 2024 - 42K bytes - Viewed (0) -
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) -
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) -
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) -
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) -
pkg/controller/volume/persistentvolume/testing/testing.go
if reflect.DeepEqual(storedClaim, claim) { logger.V(4).Info("Nothing updated claim", "PVC", klog.KObj(claim)) return true, claim, nil } // Don't modify the existing object claim = claim.DeepCopy() claim.ResourceVersion = strconv.Itoa(storedVer + 1) } else { return true, nil, fmt.Errorf("cannot update claim %s: claim not found", claim.Name) } // Store the updated object to appropriate places.
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Apr 12 15:46:12 UTC 2023 - 20.1K bytes - Viewed (0) -
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) -
pkg/serviceaccount/claims.go
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Mon Oct 30 21:15:10 UTC 2023 - 11.3K bytes - Viewed (0) -
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)