- Sort Score
- Result 10 results
- Languages All
Results 11 - 20 of 271 for claim (0.25 sec)
-
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) -
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/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) -
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) -
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) -
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) -
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) -
pkg/controller/statefulset/stateful_pod_control.go
updateClaimOwnerRefForSetAndPod(logger, claim, set, pod) if err := spc.objectMgr.UpdateClaim(claim); err != nil { return fmt.Errorf("could not update claim %s for delete policy ownerRefs: %w", claimName, err) } } } } return nil } // PodClaimIsStale returns true for a stale PVC that should block pod creation. If the scaling
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Jun 05 19:06:41 UTC 2024 - 14.9K bytes - Viewed (0) -
pkg/controller/statefulset/stateful_set_utils_test.go
set := apps.StatefulSet{} set.Name = "my-set" claim := v1.PersistentVolumeClaim{} claim.Name = "volume-my-set-2" if pod := getClaimPodName(&set, &claim); pod != "my-set-2" { t.Errorf("Expected my-set-2 found %s", pod) } claim.Name = "long-volume-my-set-20" if pod := getClaimPodName(&set, &claim); pod != "my-set-20" { t.Errorf("Expected my-set-20 found %s", pod) } claim.Name = "volume-2-my-set"
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Jun 05 19:06:41 UTC 2024 - 50.9K bytes - Viewed (0) -
pkg/kubelet/volumemanager/volume_manager_test.go
} defer os.RemoveAll(tmpDir) podManager := kubepod.NewBasicPodManager() node, pod, pv, claim := createObjects(v1.PersistentVolumeFilesystem, v1.PersistentVolumeFilesystem) claim.Status = v1.PersistentVolumeClaimStatus{ Phase: v1.ClaimPending, } kubeClient := fake.NewSimpleClientset(node, pod, pv, claim) manager := newTestVolumeManager(t, tmpDir, podManager, kubeClient, node)
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Jun 04 06:25:43 UTC 2024 - 14.1K bytes - Viewed (0)