Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 10 for GetAccessModes (0.36 sec)

  1. pkg/volume/portworx/portworx.go

    	if !util.ContainsAllAccessModes(c.plugin.GetAccessModes(), c.options.PVC.Spec.AccessModes) {
    		return nil, fmt.Errorf("invalid AccessModes %v: only AccessModes %v are supported", c.options.PVC.Spec.AccessModes, c.plugin.GetAccessModes())
    	}
    
    	if util.CheckPersistentVolumeClaimModeBlock(c.options.PVC) {
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Tue May 14 06:17:25 UTC 2024
    - 13.6K bytes
    - Viewed (0)
  2. pkg/volume/fc/fc_test.go

    	plug, err := plugMgr.FindPersistentPluginByName("kubernetes.io/fc")
    	if err != nil {
    		t.Errorf("Can't find the plugin by name")
    	}
    	if !volumetest.ContainsAccessMode(plug.GetAccessModes(), v1.ReadWriteOnce) || !volumetest.ContainsAccessMode(plug.GetAccessModes(), v1.ReadOnlyMany) {
    		t.Errorf("Expected two AccessModeTypes:  %s and %s", v1.ReadWriteOnce, v1.ReadOnlyMany)
    	}
    }
    
    type fakeDiskManager struct {
    	tmpDir       string
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Mon Aug 01 15:56:32 UTC 2022
    - 14.1K bytes
    - Viewed (0)
  3. pkg/volume/iscsi/iscsi_test.go

    	plug, err := plugMgr.FindPersistentPluginByName("kubernetes.io/iscsi")
    	if err != nil {
    		t.Errorf("Can't find the plugin by name")
    	}
    	if !volumetest.ContainsAccessMode(plug.GetAccessModes(), v1.ReadWriteOnce) || !volumetest.ContainsAccessMode(plug.GetAccessModes(), v1.ReadOnlyMany) {
    		t.Errorf("Expected two AccessModeTypes:  %s and %s", v1.ReadWriteOnce, v1.ReadOnlyMany)
    	}
    }
    
    type fakeDiskManager struct {
    	tmpDir string
    }
    
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Mon Aug 01 15:56:32 UTC 2022
    - 16.4K bytes
    - Viewed (0)
  4. pkg/volume/hostpath/host_path.go

    	return false
    }
    
    func (plugin *hostPathPlugin) SupportsSELinuxContextMount(spec *volume.Spec) (bool, error) {
    	return false, nil
    }
    
    func (plugin *hostPathPlugin) GetAccessModes() []v1.PersistentVolumeAccessMode {
    	return []v1.PersistentVolumeAccessMode{
    		v1.ReadWriteOnce,
    	}
    }
    
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Tue May 14 06:17:25 UTC 2024
    - 15.3K bytes
    - Viewed (0)
  5. pkg/volume/hostpath/host_path_test.go

    	plug, err := plugMgr.FindPersistentPluginByName(hostPathPluginName)
    	if err != nil {
    		t.Fatal("Can't find the plugin by name")
    	}
    	if len(plug.GetAccessModes()) != 1 || plug.GetAccessModes()[0] != v1.ReadWriteOnce {
    		t.Errorf("Expected %s PersistentVolumeAccessMode", v1.ReadWriteOnce)
    	}
    }
    
    func TestRecycler(t *testing.T) {
    	plugMgr := volume.VolumePluginMgr{}
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Tue Mar 14 00:37:30 UTC 2023
    - 20.5K bytes
    - Viewed (0)
  6. pkg/volume/fc/fc.go

    func (plugin *fcPlugin) SupportsMountOption() bool {
    	return true
    }
    
    func (plugin *fcPlugin) SupportsSELinuxContextMount(spec *volume.Spec) (bool, error) {
    	return true, nil
    }
    
    func (plugin *fcPlugin) GetAccessModes() []v1.PersistentVolumeAccessMode {
    	return []v1.PersistentVolumeAccessMode{
    		v1.ReadWriteOnce,
    		v1.ReadOnlyMany,
    	}
    }
    
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Tue May 14 06:17:25 UTC 2024
    - 17.4K bytes
    - Viewed (0)
  7. pkg/volume/plugins.go

    // by volumes that want to provide long term persistence of data
    type PersistentVolumePlugin interface {
    	VolumePlugin
    	// GetAccessModes describes the ways a given volume can be accessed/mounted.
    	GetAccessModes() []v1.PersistentVolumeAccessMode
    }
    
    // RecyclableVolumePlugin is an extended interface of VolumePlugin and is used
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Thu Jun 06 16:13:15 UTC 2024
    - 38.2K bytes
    - Viewed (0)
  8. pkg/volume/local/local_test.go

    		t.Errorf("Expected true")
    	}
    }
    
    func TestGetAccessModes(t *testing.T) {
    	tmpDir, plug := getPersistentPlugin(t)
    	defer os.RemoveAll(tmpDir)
    
    	modes := plug.GetAccessModes()
    	if !volumetest.ContainsAccessMode(modes, v1.ReadWriteOnce) {
    		t.Errorf("Expected AccessModeType %q", v1.ReadWriteOnce)
    	}
    
    	if volumetest.ContainsAccessMode(modes, v1.ReadWriteMany) {
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Mon May 08 10:53:39 UTC 2023
    - 22.5K bytes
    - Viewed (0)
  9. pkg/volume/iscsi/iscsi.go

    func (plugin *iscsiPlugin) SupportsMountOption() bool {
    	return true
    }
    
    func (plugin *iscsiPlugin) SupportsSELinuxContextMount(spec *volume.Spec) (bool, error) {
    	return true, nil
    }
    
    func (plugin *iscsiPlugin) GetAccessModes() []v1.PersistentVolumeAccessMode {
    	return []v1.PersistentVolumeAccessMode{
    		v1.ReadWriteOnce,
    		v1.ReadOnlyMany,
    	}
    }
    
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Tue May 14 06:17:25 UTC 2024
    - 23.4K bytes
    - Viewed (0)
  10. pkg/volume/local/local.go

    	return true
    }
    
    func (plugin *localVolumePlugin) SupportsSELinuxContextMount(spec *volume.Spec) (bool, error) {
    	return false, nil
    }
    
    func (plugin *localVolumePlugin) GetAccessModes() []v1.PersistentVolumeAccessMode {
    	// The current meaning of AccessMode is how many nodes can attach to it, not how many pods can mount it
    	return []v1.PersistentVolumeAccessMode{
    		v1.ReadWriteOnce,
    	}
    }
    
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Tue May 14 06:17:25 UTC 2024
    - 22.2K bytes
    - Viewed (0)
Back to top