- Sort Score
- Result 10 results
- Languages All
Results 11 - 20 of 56 for PersistentVolumeClaims (0.62 sec)
-
plugin/pkg/auth/authorizer/rbac/bootstrappolicy/policy.go
rbacv1helpers.NewRule(Read...).Groups(legacyGroup).Resources("pods", "replicationcontrollers", "replicationcontrollers/scale", "serviceaccounts", "services", "services/status", "endpoints", "persistentvolumeclaims", "persistentvolumeclaims/status", "configmaps").RuleOrDie(), rbacv1helpers.NewRule(Read...).Groups(legacyGroup).Resources("limitranges", "resourcequotas", "bindings", "events",
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri Mar 08 19:25:10 UTC 2024 - 34.4K bytes - Viewed (0) -
pkg/controller/volume/pvcprotection/pvc_protection_controller.go
startTime := time.Now() defer func() { logger.V(4).Info("Finished processing PVC", "PVC", klog.KRef(pvcNamespace, pvcName), "duration", time.Since(startTime)) }() pvc, err := c.pvcLister.PersistentVolumeClaims(pvcNamespace).Get(pvcName) if apierrors.IsNotFound(err) { logger.V(4).Info("PVC not found, ignoring", "PVC", klog.KRef(pvcNamespace, pvcName)) return nil } if err != nil { return err }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat May 04 18:33:12 UTC 2024 - 14K bytes - Viewed (0) -
pkg/scheduler/framework/plugins/volumebinding/volume_binding.go
pvcName = ephemeral.VolumeClaimName(pod, &vol) isEphemeral = true default: // Volume is not using a PVC, ignore continue } hasPVC = true pvc, err := pl.PVCLister.PersistentVolumeClaims(pod.Namespace).Get(pvcName) if err != nil { // The error usually has already enough context ("persistentvolumeclaim "myclaim" not found"),
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat Mar 16 14:13:06 UTC 2024 - 16.4K bytes - Viewed (0) -
cmd/kube-controller-manager/app/core.go
VolumePlugins: plugins, VolumeInformer: controllerContext.InformerFactory.Core().V1().PersistentVolumes(), ClaimInformer: controllerContext.InformerFactory.Core().V1().PersistentVolumeClaims(), ClassInformer: controllerContext.InformerFactory.Storage().V1().StorageClasses(), PodInformer: controllerContext.InformerFactory.Core().V1().Pods(),
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri May 10 08:42:31 UTC 2024 - 39K bytes - Viewed (0) -
pkg/volume/util/resize_util.go
if err != nil { return pvc, fmt.Errorf("patchPVCStatus failed to patch PVC %q: %v", pvc.Name, err) } updatedClaim, updateErr := kubeClient.CoreV1().PersistentVolumeClaims(pvc.Namespace). Patch(context.TODO(), pvc.Name, types.StrategicMergePatchType, patchBytes, metav1.PatchOptions{}, "status") if updateErr != nil {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Mon Jul 17 19:30:35 UTC 2023 - 14.8K bytes - Viewed (0) -
pkg/apis/storage/types.go
} // VolumeBindingMode indicates how PersistentVolumeClaims should be bound. type VolumeBindingMode string const ( // VolumeBindingImmediate indicates that PersistentVolumeClaims should be // immediately provisioned and bound. VolumeBindingImmediate VolumeBindingMode = "Immediate" // VolumeBindingWaitForFirstConsumer indicates that PersistentVolumeClaims
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Dec 13 20:24:57 UTC 2023 - 29.4K bytes - Viewed (0) -
pkg/volume/util/operationexecutor/operation_generator_test.go
fakeKubeClient.AddReactor("get", "persistentvolumeclaims", func(action core.Action) (bool, runtime.Object, error) { return true, pvc, nil }) fakeKubeClient.AddReactor("get", "persistentvolumes", func(action core.Action) (bool, runtime.Object, error) { return true, pv, nil }) fakeKubeClient.AddReactor("patch", "persistentvolumeclaims", func(action core.Action) (bool, runtime.Object, error) {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Apr 24 18:25:29 UTC 2024 - 16.2K bytes - Viewed (0) -
pkg/kubelet/volumemanager/volume_manager_test.go
namespace, claimName string, ) { time.Sleep(500 * time.Millisecond) volumeClaim, _ := kubeClient.CoreV1().PersistentVolumeClaims(namespace).Get(context.TODO(), claimName, metav1.GetOptions{}) volumeClaim.Status = v1.PersistentVolumeClaimStatus{ Phase: v1.ClaimBound, } kubeClient.CoreV1().PersistentVolumeClaims(namespace).Update(context.TODO(), volumeClaim, metav1.UpdateOptions{}) }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Jun 04 06:25:43 UTC 2024 - 14.1K bytes - Viewed (0) -
pkg/scheduler/framework/plugins/volumerestrictions/volume_restrictions.go
pvcs := sets.New[string]() for _, volume := range pod.Spec.Volumes { if volume.PersistentVolumeClaim == nil { continue } pvc, err := pl.pvcLister.PersistentVolumeClaims(pod.Namespace).Get(volume.PersistentVolumeClaim.ClaimName) if err != nil { return nil, err } if !v1helper.ContainsAccessMode(pvc.Spec.AccessModes, v1.ReadWriteOncePod) { continue }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri Oct 20 17:40:39 UTC 2023 - 12.5K bytes - Viewed (0) -
pkg/controller/statefulset/stateful_set_test.go
t.Errorf("bad claim ownerRefs: %s: %v", claim.Name, claim.GetOwnerReferences()) } } } claims, _ := om.claimsLister.PersistentVolumeClaims(set.Namespace).List(labels.Everything()) if len(claims) != len(pods) { t.Errorf("Unexpected number of claims: %d", len(claims)) } for _, claim := range claims {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat May 04 18:33:12 UTC 2024 - 33.1K bytes - Viewed (0)