- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 122 for claims0 (0.32 sec)
-
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) -
pkg/controller/volume/persistentvolume/pv_controller_test.go
}) if err != nil { return err } // delete the claim obj := ctrl.claims.List()[0] claim := obj.(*v1.PersistentVolumeClaim) reactor.DeleteClaimEvent(claim) // wait until claim is cleared from cache, i.e., deleteClaim is called err = wait.Poll(10*time.Millisecond, wait.ForeverTestTimeout, func() (bool, error) { return len(ctrl.claims.ListKeys()) == 0, nil
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/kubelet/cm/dra/manager_test.go
if s.timeout != nil { time.Sleep(*s.timeout) } if s.prepareResourcesResponse == nil { deviceName := "claim-" + req.Claims[0].Uid result := s.driverName + "/" + driverClassName + "=" + deviceName return &drapbv1.NodePrepareResourcesResponse{ Claims: map[string]*drapbv1.NodePrepareResourceResponse{ req.Claims[0].Uid: { CDIDevices: []string{result}, }, }, }, nil }
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/volume/persistentvolume/provision_test.go
// syncVolume/syncClaim on all volumes/claims (simulating "periodic sync"). // 4. If some changes were done by step 3., go to 2. (simulation of // "volume/claim updated" events, eventually performing step 3. again) // 5. When 3. does not do any changes, finish the tests and compare final set // of volumes/claims with expected claims/volumes and report differences. //
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Apr 24 18:25:29 UTC 2024 - 35.3K bytes - Viewed (0) -
pkg/controller/resourceclaim/controller_test.go
} } func normalizeClaims(claims []resourcev1alpha2.ResourceClaim) []resourcev1alpha2.ResourceClaim { sort.Slice(claims, func(i, j int) bool { if claims[i].Namespace < claims[j].Namespace { return true } if claims[i].Namespace > claims[j].Namespace { return false } return claims[i].Name < claims[j].Name }) for i := range claims { if len(claims[i].Status.ReservedFor) == 0 {
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/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/volumebinding/binder.go
func (b *volumeBinder) revertAssumedPVCs(claims []*v1.PersistentVolumeClaim) { for _, claim := range claims { b.pvcCache.Restore(getPVCName(claim)) } } // hasEnoughCapacity checks whether the provisioner has enough capacity left for a new volume of the given size // that is available from the node.
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu May 09 14:55:34 UTC 2024 - 42.6K bytes - Viewed (0) -
pkg/controller/statefulset/stateful_set_test.go
if hasNamedOwnerRef(claim, podName) || hasNamedOwnerRef(claim, set.Name) { t.Errorf("bad claim ownerRefs: %s: %v", claim.Name, claim.GetOwnerReferences()) } case scaledownPolicy == retain && deletionPolicy == delete: if hasNamedOwnerRef(claim, podName) || !hasNamedOwnerRef(claim, set.Name) { t.Errorf("bad claim ownerRefs: %s: %v", claim.Name, claim.GetOwnerReferences()) }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat May 04 18:33:12 UTC 2024 - 33.1K bytes - Viewed (0) -
cmd/sts-handlers.go
// metadata map claims[expClaim] = UTCNow().Add(time.Duration(expiry) * time.Second).Unix() claims[subClaim] = parentUser claims[roleArnClaim] = roleArn.String() claims[parentClaim] = parentUser // Add all other claims from the plugin **without** replacing any // existing claims. for k, v := range res.Success.Claims { if _, ok := claims[k]; !ok { claims[k] = v } }
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Tue Jun 11 03:13:30 UTC 2024 - 33.9K 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)