- Sort Score
- Result 10 results
- Languages All
Results 21 - 30 of 71 for PersistentVolumeClaims (0.32 sec)
-
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/volumebinding/binder_test.go
podInformer := informerFactory.Core().V1().Pods() nodeInformer := informerFactory.Core().V1().Nodes() csiNodeInformer := informerFactory.Storage().V1().CSINodes() pvcInformer := informerFactory.Core().V1().PersistentVolumeClaims() classInformer := informerFactory.Storage().V1().StorageClasses() csiDriverInformer := informerFactory.Storage().V1().CSIDrivers() csiStorageCapacityInformer := informerFactory.Storage().V1().CSIStorageCapacities()
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu Apr 25 09:46:58 UTC 2024 - 82.8K bytes - Viewed (0) -
pkg/controller/volume/attachdetach/metrics/metrics_test.go
}, }, }, }, Status: v1.PodStatus{ Phase: v1.PodPhase("Running"), }, } fakePodInformer.Informer().GetStore().Add(pod) pvcInformer := fakeInformerFactory.Core().V1().PersistentVolumeClaims() pvInformer := fakeInformerFactory.Core().V1().PersistentVolumes() pvc := &v1.PersistentVolumeClaim{ ObjectMeta: metav1.ObjectMeta{ Name: "metric-test-pvc", Namespace: "metric-test",
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri Mar 01 10:42:15 UTC 2024 - 6.1K 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) -
staging/src/k8s.io/api/storage/v1/types.go
Items []StorageClass `json:"items" protobuf:"bytes,2,rep,name=items"` } // VolumeBindingMode indicates how PersistentVolumeClaims should be bound. // +enum type VolumeBindingMode string const ( // VolumeBindingImmediate indicates that PersistentVolumeClaims should be // immediately provisioned and bound. This is the default mode. VolumeBindingImmediate VolumeBindingMode = "Immediate"
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu May 23 17:42:49 UTC 2024 - 32K bytes - Viewed (0) -
pkg/controller/volume/persistentvolume/pv_controller_base.go
modified := updateMigrationAnnotations(logger, ctrl.csiMigratedPluginManager, ctrl.translator, claimClone.Annotations, true) if !modified { return claimClone, nil } newClaim, err := ctrl.kubeClient.CoreV1().PersistentVolumeClaims(claimClone.Namespace).Update(ctx, claimClone, metav1.UpdateOptions{}) if err != nil { return nil, fmt.Errorf("persistent Volume Controller can't anneal migration annotations: %v", err) }
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/scheduler/framework/plugins/nodevolumelimits/csi.go
return err } continue } if pvcName == "" { return fmt.Errorf("PersistentVolumeClaim had no name") } pvc, err := pl.pvcLister.PersistentVolumeClaims(pod.Namespace).Get(pvcName) if err != nil { if newPod { // The PVC is required to proceed with // scheduling of a new pod because it cannot // run without it. Bail out immediately.
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue May 14 18:07:11 UTC 2024 - 16.6K bytes - Viewed (0) -
pkg/registry/core/persistentvolumeclaim/storage/storage_test.go
restOptions := generic.RESTOptions{ StorageConfig: etcdStorage, Decorator: generic.UndecoratedStorage, DeleteCollectionWorkers: 1, ResourcePrefix: "persistentvolumeclaims", } persistentVolumeClaimStorage, statusStorage, err := NewREST(restOptions) if err != nil { t.Fatalf("unexpected error from REST storage: %v", err) }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Apr 24 18:25:29 UTC 2024 - 8.9K bytes - Viewed (0) -
pkg/controller/statefulset/stateful_set_utils.go
return refs } } return append(refs, *metav1.NewControllerRef(owner, gvk)) } // getPersistentVolumeClaims gets a map of PersistentVolumeClaims to their template names, as defined in set. The // returned PersistentVolumeClaims are each constructed with a the name specific to the Pod. This name is determined // by getPersistentVolumeClaimName.
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
obj, err = ctrl.claimLister.PersistentVolumeClaims(volume.Spec.ClaimRef.Namespace).Get(volume.Spec.ClaimRef.Name) if err != nil && !apierrors.IsNotFound(err) { return err } found = !apierrors.IsNotFound(err) if !found { obj, err = ctrl.kubeClient.CoreV1().PersistentVolumeClaims(volume.Spec.ClaimRef.Namespace).Get(ctx, volume.Spec.ClaimRef.Name, metav1.GetOptions{})
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri May 10 08:42:31 UTC 2024 - 89.2K bytes - Viewed (0)