- Sort Score
- Result 10 results
- Languages All
Results 31 - 40 of 320 for persistentVolumeClaim (0.48 sec)
-
pkg/controller/volume/persistentvolume/index_test.go
ref "k8s.io/client-go/tools/reference" "k8s.io/component-helpers/storage/volume" "k8s.io/kubernetes/pkg/volume/util" ) func makePVC(size string, modfn func(*v1.PersistentVolumeClaim)) *v1.PersistentVolumeClaim { fs := v1.PersistentVolumeFilesystem pvc := v1.PersistentVolumeClaim{ ObjectMeta: metav1.ObjectMeta{ Name: "claim01", Namespace: "myns", }, Spec: v1.PersistentVolumeClaimSpec{
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Mon Aug 21 13:31:28 UTC 2023 - 44K bytes - Viewed (0) -
pkg/controller/volume/persistentvolume/framework_test.go
func claimWithAnnotation(name, value string, claims []*v1.PersistentVolumeClaim) []*v1.PersistentVolumeClaim { if claims[0].Annotations == nil { claims[0].Annotations = map[string]string{name: value} } else { claims[0].Annotations[name] = value } return claims } func claimWithDataSource(name, kind, apiGroup string, claims []*v1.PersistentVolumeClaim) []*v1.PersistentVolumeClaim {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Nov 01 09:54:00 UTC 2023 - 38.3K bytes - Viewed (0) -
pkg/controller/volume/expand/expand_controller_test.go
} } } func applyPVCPatch(originalPVC *v1.PersistentVolumeClaim, patch []byte) (*v1.PersistentVolumeClaim, error) { pvcData, err := json.Marshal(originalPVC) if err != nil { return nil, fmt.Errorf("failed to marshal pvc with %v", err) } updated, err := strategicpatch.StrategicMergePatch(pvcData, patch, v1.PersistentVolumeClaim{}) if err != nil {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu Apr 18 11:00:37 UTC 2024 - 7.9K bytes - Viewed (0) -
pkg/scheduler/framework/plugins/nodevolumelimits/csi_test.go
ephemeralEnabled: true, extraClaims: []v1.PersistentVolumeClaim{*ephemeralClaim}, driverNames: []string{ebsCSIDriverName}, test: "ephemeral volume unbound", }, { newPod: ephemeralVolumePod, filterName: "csi", ephemeralEnabled: true, extraClaims: []v1.PersistentVolumeClaim{*ephemeralClaim}, driverNames: []string{ebsCSIDriverName},
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue May 14 18:07:11 UTC 2024 - 28.6K bytes - Viewed (0) -
pkg/controller/volume/pvcprotection/pvc_protection_controller.go
// Check whether pvc is used by pod only if pod is scheduled, because // kubelet sees pods after they have been scheduled and it won't allow // starting a pod referencing a PVC with a non-nil deletionTimestamp. if pod.Spec.NodeName != "" { for _, volume := range pod.Spec.Volumes {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat May 04 18:33:12 UTC 2024 - 14K bytes - Viewed (0) -
pkg/controller/volume/persistentvolume/pv_controller.go
updated, err := ctrl.assignDefaultStorageClass(ctx, claim) if err != nil { metrics.RecordRetroactiveStorageClassMetric(false) return fmt.Errorf("can't update PersistentVolumeClaim[%q]: %w", claimToClaimKey(claim), err) } if updated {
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/volume/persistentvolume/testing/testing.go
// test and reports differences. func (r *VolumeReactor) CheckClaims(expectedClaims []*v1.PersistentVolumeClaim) error { r.lock.Lock() defer r.lock.Unlock() expectedMap := make(map[string]*v1.PersistentVolumeClaim) gotMap := make(map[string]*v1.PersistentVolumeClaim) for _, c := range expectedClaims { // Don't modify the existing object c = c.DeepCopy() c.ResourceVersion = ""
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/kubelet/volumemanager/populator/desired_state_of_world_populator_test.go
func TestCheckVolumeFSResize(t *testing.T) { setCapacity := func(pv *v1.PersistentVolume, pvc *v1.PersistentVolumeClaim, capacity int) { pv.Spec.Capacity = volumeCapacity(capacity) pvc.Spec.Resources.Requests = volumeCapacity(capacity) } testcases := []struct { resize func(*testing.T, *v1.PersistentVolume, *v1.PersistentVolumeClaim, *desiredStateOfWorldPopulator)
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Apr 24 18:25:29 UTC 2024 - 51.4K bytes - Viewed (0) -
pkg/controller/statefulset/stateful_set_utils_test.go
for i := range pod.Spec.Volumes { pod.Spec.Volumes[i].PersistentVolumeClaim = nil } if storageMatches(set, pod) { t.Error("Pod with invalid Volumes claim valid storage") } pod = newStatefulSetPod(set, 1) for i := range pod.Spec.Volumes { if pod.Spec.Volumes[i].PersistentVolumeClaim != nil { pod.Spec.Volumes[i].PersistentVolumeClaim.ClaimName = "foo" } } if storageMatches(set, pod) {
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/scheduler/testing/framework/fake_listers.go
} func (f persistentVolumeClaimNamespaceLister) List(selector labels.Selector) (ret []*v1.PersistentVolumeClaim, err error) { return nil, fmt.Errorf("not implemented") } // PersistentVolumeClaimLister declares a []v1.PersistentVolumeClaim type for testing. type PersistentVolumeClaimLister []v1.PersistentVolumeClaim var _ corelisters.PersistentVolumeClaimLister = PersistentVolumeClaimLister{}
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Mon Nov 20 10:14:08 UTC 2023 - 10.1K bytes - Viewed (0)