Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 80 for volumeModes (0.17 sec)

  1. pkg/apis/core/fuzzer/fuzzer.go

    			}
    		},
    		func(i *core.PersistentVolumeClaimSpec, c fuzz.Continue) {
    			// Match defaulting in pkg/apis/core/v1/defaults.go.
    			volumeMode := core.PersistentVolumeMode(c.RandString())
    			if volumeMode == "" {
    				volumeMode = core.PersistentVolumeFilesystem
    			}
    			i.VolumeMode = &volumeMode
    		},
    		func(d *core.DNSPolicy, c fuzz.Continue) {
    			policies := []core.DNSPolicy{core.DNSClusterFirst, core.DNSDefault}
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Mon Feb 26 04:32:01 UTC 2024
    - 18.5K bytes
    - Viewed (0)
  2. pkg/controller/volume/persistentvolume/index_test.go

    }
    
    func TestVolumeModeCheck(t *testing.T) {
    
    	blockMode := v1.PersistentVolumeBlock
    	filesystemMode := v1.PersistentVolumeFilesystem
    
    	// If feature gate is enabled, VolumeMode will always be defaulted
    	// If feature gate is disabled, VolumeMode is dropped by API and ignored
    	scenarios := map[string]struct {
    		isExpectedMismatch bool
    		vol                *v1.PersistentVolume
    		pvc                *v1.PersistentVolumeClaim
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Mon Aug 21 13:31:28 UTC 2023
    - 44K bytes
    - Viewed (0)
  3. pkg/kubelet/volumemanager/reconciler/reconstruct_common.go

    	volumePath     string
    	pluginName     string
    	volumeMode     v1.PersistentVolumeMode
    }
    
    func (p podVolume) MarshalLog() interface{} {
    	return struct {
    		PodName        string `json:"podName"`
    		VolumeSpecName string `json:"volumeSpecName"`
    		VolumePath     string `json:"volumePath"`
    		PluginName     string `json:"pluginName"`
    		VolumeMode     string `json:"volumeMode"`
    	}{
    		PodName:        string(p.podName),
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Tue Apr 09 07:34:33 UTC 2024
    - 14.1K bytes
    - Viewed (0)
  4. pkg/kubelet/volumemanager/reconciler/reconstruct_test.go

    		})
    	}
    }
    
    func getPodPVCAndPV(volumeMode v1.PersistentVolumeMode, podName, pvName, pvcName string) (*v1.Pod, *v1.PersistentVolume, *v1.PersistentVolumeClaim) {
    	pv := &v1.PersistentVolume{
    		ObjectMeta: metav1.ObjectMeta{
    			Name: pvName,
    			UID:  "pvuid",
    		},
    		Spec: v1.PersistentVolumeSpec{
    			ClaimRef:   &v1.ObjectReference{Name: pvcName},
    			VolumeMode: &volumeMode,
    		},
    	}
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Tue Jun 04 06:25:43 UTC 2024
    - 14.8K bytes
    - Viewed (0)
  5. pkg/controller/volume/persistentvolume/metrics/metrics.go

    			StabilityLevel: metrics.ALPHA,
    		})
    )
    
    // volumeCount counts by PluginName and VolumeMode.
    type volumeCount map[string]map[string]int
    
    func (v volumeCount) add(pluginName string, volumeMode string) {
    	count, ok := v[pluginName]
    	if !ok {
    		count = map[string]int{}
    	}
    	count[volumeMode]++
    	v[pluginName] = count
    }
    
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Tue Oct 25 13:09:16 UTC 2022
    - 10.5K bytes
    - Viewed (0)
  6. pkg/volume/util/operationexecutor/operation_executor_test.go

    	volumesToMount := make([]VolumeToMount, numVolumesToMap)
    	secretName := "secret-volume"
    	volumeName := v1.UniqueVolumeName(secretName)
    	volumeMode := v1.PersistentVolumeBlock
    	tmpSpec := &volume.Spec{PersistentVolume: &v1.PersistentVolume{Spec: v1.PersistentVolumeSpec{VolumeMode: &volumeMode}}}
    
    	// Act
    	for i := range volumesToMount {
    		podName := "pod-" + strconv.Itoa(i+1)
    		pod := getTestPodWithSecret(podName, secretName)
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Tue May 14 06:17:25 UTC 2024
    - 26.9K bytes
    - Viewed (0)
  7. pkg/volume/local/local_test.go

    				t.Fatalf("PersistentVolume object nil")
    			}
    
    			if rec.Spec.PersistentVolume.Spec.VolumeMode == nil {
    				t.Fatalf("Volume mode has not been set.")
    			}
    
    			if *rec.Spec.PersistentVolume.Spec.VolumeMode != v1.PersistentVolumeFilesystem {
    				t.Errorf("Unexpected volume mode %q", *rec.Spec.PersistentVolume.Spec.VolumeMode)
    			}
    
    			ls := pv.Spec.PersistentVolumeSource.Local
    			if ls == nil {
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Mon May 08 10:53:39 UTC 2023
    - 22.5K bytes
    - Viewed (0)
  8. pkg/apis/core/v1/defaults.go

    	}
    	if obj.Spec.PersistentVolumeReclaimPolicy == "" {
    		obj.Spec.PersistentVolumeReclaimPolicy = v1.PersistentVolumeReclaimRetain
    	}
    	if obj.Spec.VolumeMode == nil {
    		obj.Spec.VolumeMode = new(v1.PersistentVolumeMode)
    		*obj.Spec.VolumeMode = v1.PersistentVolumeFilesystem
    	}
    }
    func SetDefaults_PersistentVolumeClaim(obj *v1.PersistentVolumeClaim) {
    	if obj.Status.Phase == "" {
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Fri Apr 19 22:24:15 UTC 2024
    - 14.8K bytes
    - Viewed (0)
  9. pkg/volume/fc/fc.go

    		manager: manager,
    		io:      &osIOHandler{},
    		plugin:  plugin,
    	}
    
    	volumeMode, err := util.GetVolumeMode(spec)
    	if err != nil {
    		return nil, err
    	}
    
    	klog.V(5).Infof("fc: newMounterInternal volumeMode %s", volumeMode)
    	return &fcDiskMounter{
    		fcDisk:       fcDisk,
    		fsType:       fc.FSType,
    		volumeMode:   volumeMode,
    		readOnly:     readOnly,
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Tue May 14 06:17:25 UTC 2024
    - 17.4K bytes
    - Viewed (0)
  10. pkg/volume/util/util.go

    		return v1.PersistentVolumeFilesystem, nil
    	}
    	if volumeSpec.PersistentVolume.Spec.VolumeMode != nil {
    		return *volumeSpec.PersistentVolume.Spec.VolumeMode, nil
    	}
    	return "", fmt.Errorf("cannot get volumeMode for volume: %v", volumeSpec.Name())
    }
    
    // GetPersistentVolumeClaimQualifiedName returns a qualified name for pvc.
    func GetPersistentVolumeClaimQualifiedName(claim *v1.PersistentVolumeClaim) string {
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Fri May 31 12:32:15 UTC 2024
    - 28.8K bytes
    - Viewed (0)
Back to top